Implementing Propagators API to use Context #446

codeboten · 2020-02-22T01:07:56Z

As per the the Propagators API spec: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/api-propagators.md, the propagation API now uses the Context API as a mechanism for propagation.

As part of this change:

inject/extract now take an optional context parameter
extract now returns a Context object
removed binary format as they're not currently in the spec
added CompositePropagator to support configuring multiple propagators for the same format

Fixes #415

Signed-off-by: Alex Boten <aboten@lightstep.com>

codecov-io · 2020-02-22T01:20:40Z

Codecov Report

Merging #446 into master will decrease coverage by 0.11%.
The diff coverage is 91.35%.

@@            Coverage Diff             @@
##           master     #446      +/-   ##
==========================================
- Coverage   88.78%   88.66%   -0.12%     
==========================================
  Files          42       43       +1     
  Lines        2167     2206      +39     
  Branches      246      249       +3     
==========================================
+ Hits         1924     1956      +32     
- Misses        170      176       +6     
- Partials       73       74       +1

Impacted Files	Coverage Δ
...opentelemetry/sdk/context/propagation/b3_format.py	`87.27% <100%> (ø)`	⬆️
...try-api/src/opentelemetry/propagators/composite.py	`100% <100%> (ø)`
...-ext-flask/src/opentelemetry/ext/flask/__init__.py	`89.79% <100%> (+0.9%)`	⬆️
...ts/src/opentelemetry/ext/http_requests/__init__.py	`89.47% <100%> (ø)`	⬆️
...src/opentelemetry/ext/opentracing_shim/__init__.py	`96.03% <100%> (+0.09%)`	⬆️
.../opentelemetry/trace/propagation/httptextformat.py	`100% <100%> (ø)`
...etry-api/src/opentelemetry/propagators/__init__.py	`75% <71.42%> (ø)`
...pi/src/opentelemetry/trace/propagation/__init__.py	`84.61% <81.81%> (ø)`
...ry/trace/propagation/tracecontexthttptextformat.py	`84.28% <85.71%> (ø)`
...ry-ext-wsgi/src/opentelemetry/ext/wsgi/__init__.py	`68.14% <85.71%> (-0.05%)`	⬇️
... and 3 more

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 005575e...90c0535. Read the comment docs.

opentelemetry-api/tests/context/propagation/test_tracecontexthttptextformat.py

c24t · 2020-02-25T23:27:42Z

opentelemetry-api/src/opentelemetry/trace/propagation/__init__.py

@@ -13,7 +13,22 @@
 # limitations under the License.
 from typing import Optional

-from opentelemetry.trace import INVALID_SPAN_CONTEXT, Span, SpanContext
+from opentelemetry import trace as trace_api
+from opentelemetry.context import get_value, set_current, set_value


set_current is unused. I wondered why pyflakes caught this and not pylint -- it looks like we ignore unused imports in init modules by default.

toumorokoshi

Nice! A couple questions, one those are discussed I think I'm happy to move to approved.

One thing I think that really needs some thought is whether context extracted from propagators should be attached as well. Probably the main blocker for me.

toumorokoshi · 2020-02-27T06:26:42Z

opentelemetry-api/src/opentelemetry/context/propagation/tracecontexthttptextformat.py

@@ -16,9 +16,12 @@
 import typing


should tracecontext be moved to trace/propagation? It's a valid hierarchy. I don't see anything in the spec that calls out specifically where this should be: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/library-layout.md

makes more sense in trace/propagation than where it currently is. moved it.

opentelemetry-api/tests/context/propagation/test_tracecontexthttptextformat.py

toumorokoshi · 2020-02-27T06:33:40Z

ext/opentelemetry-ext-flask/src/opentelemetry/ext/flask/__init__.py

-        otel_wsgi.get_header_from_environ, environ
-    )
+    context = propagators.extract(otel_wsgi.get_header_from_environ, environ)
+    parent_span = get_span_from_context(context).get_context()


I think we may need to add another line here to extract or pass through correlation context, since we're not attaching this context as we start the activation.

Would it make sense to add context attach / detach to these extensions?

i think so. added an attach/detach to flask and wsgi extensions.

Signed-off-by: Alex Boten <aboten@lightstep.com>

mauriciovasquezbernal

The PR overall looks pretty good! I have some comments, many of them are just details.

There is one thing I noticed after this PR, extract now returns a Context with a DefaultSpan inside instead of a SpanContext. If I am not wrong, the propagators were one of the main consumers of the API that allows to create a span passing a SpanContext as parent.

Maybe it's time to consider moving ahead with #345.

opentelemetry-api/src/opentelemetry/propagators/composite.py

opentelemetry-api/tests/propagators/test_composite.py

opentelemetry-api/src/opentelemetry/trace/propagation/httptextformat.py

opentelemetry-api/src/opentelemetry/propagators/composite.py

opentelemetry-api/tests/trace/propagation/test_tracecontexthttptextformat.py

opentelemetry-api/src/opentelemetry/propagators/composite.py

opentelemetry-api/tests/trace/propagation/test_tracecontexthttptextformat.py

mauriciovasquezbernal · 2020-03-05T14:21:57Z

opentelemetry-sdk/tests/context/propagation/test_b3_format.py

@@ -28,7 +32,8 @@ def get_as_list(dict_object, key):

 def get_child_parent_new_carrier(old_carrier):

-    parent_context = FORMAT.extract(get_as_list, old_carrier)
+    ctx = FORMAT.extract(get_as_list, old_carrier)
+    parent_context = get_span_from_context(ctx).get_context()


Not related to this PR: I think we'll have to rename get_context() to get_spancontext(). I'm already confused with Context and SpanContext being two very different things.

I agree, this would be good to update. Think there was a similar comment made previously.

ext/opentelemetry-ext-http-requests/src/opentelemetry/ext/http_requests/__init__.py

Co-Authored-By: Mauricio Vásquez <mauricio@kinvolk.io>

opentelemetry-api/src/opentelemetry/propagators/composite.py

mauriciovasquezbernal

An extra couple of comments. Once documentation is updated it should be ok from my side.

opentelemetry-api/tests/propagators/test_composite.py

ocelotl

LGTM! Just minor changes/suggestions 👍

ext/opentelemetry-ext-wsgi/src/opentelemetry/ext/wsgi/__init__.py

ocelotl · 2020-03-06T00:50:17Z

opentelemetry-api/tests/propagators/test_composite.py

+# limitations under the License.
+
+import unittest
+from logging import ERROR


This is unused.

Good catch, fixed!

opentelemetry-api/tests/propagators/test_composite.py

mauriciovasquezbernal

Thanks a lot for taking into consideration all my comments. LGTM!

toumorokoshi

Looks good, thanks!

toumorokoshi · 2020-03-06T19:02:45Z

opentelemetry-api/src/opentelemetry/propagators/composite.py

+logger = logging.getLogger(__name__)
+
+
+class CompositeHTTPPropagator(httptextformat.HTTPTextFormat):


I recall these are called "Chained" propagators in the OTEP. Not sure if anything official made it to the spec.

Can you confirm that the naming is consistent? if you haven't already.

Confirmed it's composite propagator in the spec: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/api-propagators.md#composite-propagator

Rename TracerSource to TracerProvider (open-telemetry#441) Following discussion in open-telemetry#434, align the name with the specification. Co-authored-by: Chris Kleinknecht <libc@google.com> Fix new ext READMEs (open-telemetry#444) Some of the new ext packages had ReStructuredText errors. PyPI rejected the uploads for these packages with: HTTPError: 400 Client Error: The description failed to render for 'text/x-rst'. See https://pypi.org/help/#description-content-type for more information. for url: https://upload.pypi.org/legacy/ Adding attach/detach methods as per spec (open-telemetry#429) This change updates the Context API with the following: - removes the remove_value method - removes the set_current method - adds attach and detach methods Fixes open-telemetry#420 Co-authored-by: Chris Kleinknecht <libc@google.com> Make Counter and MinMaxSumCount aggregators thread safe (open-telemetry#439) OT Collector trace exporter (open-telemetry#405) Based on the OpenCensus agent exporter. Fixes open-telemetry#343 Co-authored-by: Chris Kleinknecht <libc@google.com> API: Renaming TraceOptions to TraceFlags (open-telemetry#450) Renaming TraceOptions to TraceFlags, which is the term used to describe the flags associated with the trace in the OpenTelemetry specification. Closes open-telemetry#434 api: Implement "named" meters + Remove "Batcher" from Meter constructor (open-telemetry#431) Implements open-telemetry#221. Also fixes open-telemetry#394. Stateful.py and stateless.py in metrics example folder are not changed to use the new loader in anticipation of open-telemetry#422 being merged first and removing them. Lastly, moves InstrumentationInfo from trace.py in the sdk to utils. Prepare to host on readthedocs.org (open-telemetry#452) sdk: Implement observer instrument (open-telemetry#425) Observer instruments are used to capture a current set of values at a point in time [1]. This commit extends the Meter interface to allow to register an observer instrument by pasing a callback that will be executed at collection time. The logic inside collection is updated to consider these instruments and a new ObserverAggregator is implemented. [1] https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/api-metrics.md#observer-instruments sdk: fix ConsoleSpanExporter (open-telemetry#455) 19d573a ("Add io and formatter options to console exporter (open-telemetry#412)") changed the way spans are printed by using write() instead of print(). In Python 3.x sys.stdout is line-buffered, so the spans were not being printed to the console at the right timing. This commit fixes that by adding an explicit flush() call at the end of the export function , it also changes the default formatter to include a line break. To be precise, only one of the changes was needed to solve the problem, but as a matter of completness both are included, i.e, to handle the case where the formatter chosen by the user doesn't append a line break. jaeger: Usage README Update for opentelemetry-ext-jaeger (open-telemetry#459) Usage docs for opentelemetry-ext-jaeger need to be updated after the change to `TracerSource` with v0.4. Looks like it was partially updated already. Users following the usage docs will currently run into this error: `AttributeError: 'Tracer' object has no attribute 'add_span_processor'` api: Implementing Propagators API to use Context (open-telemetry#446) Implementing Propagators API to use Context. Moving tracecontexthttptextformat to trace/propagation, as TraceContext is specific to trace rather that broader context propagation. Using attach/detach for wsgi and flask extensions, enabling activation of the full context rather that activating of a sub component such as traces. Adding a composite propagator. Co-authored-by: Mauricio Vásquez <mauricio@kinvolk.io>

Total Changelog: Documentations has been significantly overhauled, including: * a getting started guide * examples has been consolidated to an docs/examples folder * several minor improvements to the examples in each extension's readme. - Adding Correlation Context API and propagator ([open-telemetry#471](open-telemetry#471)) - Adding a global configuration module to simplify setting and getting globals ([open-telemetry#466](open-telemetry#466)) - Rename metric handle to bound metric ([open-telemetry#470](open-telemetry#470)) - Moving resources to sdk ([open-telemetry#464](open-telemetry#464)) - Implementing propagators to API to use context ([open-telemetry#446](open-telemetry#446)) - Implement observer instrument for metrics ([open-telemetry#425](open-telemetry#425)) - Adding named meters, removing batchers ([open-telemetry#431](open-telemetry#431)) - Renaming TraceOptions to TraceFlags ([open-telemetry#450](open-telemetry#450)) - Renaming TracerSource to TraceProvider ([open-telemetry#441](open-telemetry#441)) - Adding Correlation Context SDK and propagator ([open-telemetry#471](open-telemetry#471)) - Adding OT Collector metrics exporter ([open-telemetry#454](open-telemetry#454)) - Improve validation of attributes ([open-telemetry#460](open-telemetry#460)) - Re-raise errors caught in opentelemetry.sdk.trace.Tracer.use_span() (open-telemetry#469) ([open-telemetry#469](open-telemetry#469)) - Adding named meters, removing batchers ([open-telemetry#431](open-telemetry#431)) - Make counter and MinMaxSumCount aggregators thread safe ([open-telemetry#439](open-telemetry#439)) - Initial release. Support is included for both trace and metrics.

Rename TracerSource to TracerProvider (open-telemetry#441) Following discussion in open-telemetry#434, align the name with the specification. Co-authored-by: Chris Kleinknecht <libc@google.com> Fix new ext READMEs (open-telemetry#444) Some of the new ext packages had ReStructuredText errors. PyPI rejected the uploads for these packages with: HTTPError: 400 Client Error: The description failed to render for 'text/x-rst'. See https://pypi.org/help/#description-content-type for more information. for url: https://upload.pypi.org/legacy/ Adding attach/detach methods as per spec (open-telemetry#429) This change updates the Context API with the following: - removes the remove_value method - removes the set_current method - adds attach and detach methods Fixes open-telemetry#420 Co-authored-by: Chris Kleinknecht <libc@google.com> Make Counter and MinMaxSumCount aggregators thread safe (open-telemetry#439) OT Collector trace exporter (open-telemetry#405) Based on the OpenCensus agent exporter. Fixes open-telemetry#343 Co-authored-by: Chris Kleinknecht <libc@google.com> API: Renaming TraceOptions to TraceFlags (open-telemetry#450) Renaming TraceOptions to TraceFlags, which is the term used to describe the flags associated with the trace in the OpenTelemetry specification. Closes open-telemetry#434 api: Implement "named" meters + Remove "Batcher" from Meter constructor (open-telemetry#431) Implements open-telemetry#221. Also fixes open-telemetry#394. Stateful.py and stateless.py in metrics example folder are not changed to use the new loader in anticipation of open-telemetry#422 being merged first and removing them. Lastly, moves InstrumentationInfo from trace.py in the sdk to utils. Prepare to host on readthedocs.org (open-telemetry#452) sdk: Implement observer instrument (open-telemetry#425) Observer instruments are used to capture a current set of values at a point in time [1]. This commit extends the Meter interface to allow to register an observer instrument by pasing a callback that will be executed at collection time. The logic inside collection is updated to consider these instruments and a new ObserverAggregator is implemented. [1] https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/api-metrics.md#observer-instruments sdk: fix ConsoleSpanExporter (open-telemetry#455) 19d573a ("Add io and formatter options to console exporter (open-telemetry#412)") changed the way spans are printed by using write() instead of print(). In Python 3.x sys.stdout is line-buffered, so the spans were not being printed to the console at the right timing. This commit fixes that by adding an explicit flush() call at the end of the export function , it also changes the default formatter to include a line break. To be precise, only one of the changes was needed to solve the problem, but as a matter of completness both are included, i.e, to handle the case where the formatter chosen by the user doesn't append a line break. jaeger: Usage README Update for opentelemetry-ext-jaeger (open-telemetry#459) Usage docs for opentelemetry-ext-jaeger need to be updated after the change to `TracerSource` with v0.4. Looks like it was partially updated already. Users following the usage docs will currently run into this error: `AttributeError: 'Tracer' object has no attribute 'add_span_processor'` api: Implementing Propagators API to use Context (open-telemetry#446) Implementing Propagators API to use Context. Moving tracecontexthttptextformat to trace/propagation, as TraceContext is specific to trace rather that broader context propagation. Using attach/detach for wsgi and flask extensions, enabling activation of the full context rather that activating of a sub component such as traces. Adding a composite propagator. Co-authored-by: Mauricio Vásquez <mauricio@kinvolk.io>

Alex Boten added 3 commits February 21, 2020 16:23

Implementing Propagators API to use Context

0f3b8c1

Signed-off-by: Alex Boten <aboten@lightstep.com>

Merge remote-tracking branch 'origin/master' into propatationapi

bfee040

minor cleanups

e74972c

Signed-off-by: Alex Boten <aboten@lightstep.com>

codeboten added the WIP Work in progress label Feb 22, 2020

codeboten requested a review from a team as a code owner February 22, 2020 01:07

ocelotl requested changes Feb 24, 2020

View reviewed changes

opentelemetry-api/tests/context/propagation/test_tracecontexthttptextformat.py Show resolved Hide resolved

c24t reviewed Feb 25, 2020

View reviewed changes

c24t mentioned this pull request Feb 25, 2020

Lint unused imports in init modules #447

Closed

toumorokoshi suggested changes Feb 27, 2020

View reviewed changes

toumorokoshi added this to the Beta milestone Feb 27, 2020

Alex Boten added 7 commits March 2, 2020 09:48

Merge remote-tracking branch 'origin/master' into propatationapi

1bb75a5

moving tracecontexthttptextformat to trace/propagation

fcabf00

Signed-off-by: Alex Boten <aboten@lightstep.com>

moving test to match src change

fe6bf4b

Signed-off-by: Alex Boten <aboten@lightstep.com>

Merge remote-tracking branch 'origin/master' into propatationapi

6484b1b

attach/detach for wsgi and flask extensions

914ad6b

lint fixes

8d22934

adding composite propagator

03ea072

codeboten changed the title ~~[WIP] Implementing Propagators API to use Context~~ Implementing Propagators API to use Context Mar 5, 2020

codeboten removed the WIP Work in progress label Mar 5, 2020

codeboten requested review from toumorokoshi and ocelotl March 5, 2020 01:22

mauriciovasquezbernal reviewed Mar 5, 2020

View reviewed changes

codeboten and others added 5 commits March 5, 2020 09:16

Apply suggestions from code review

5bc4f60

Co-Authored-By: Mauricio Vásquez <mauricio@kinvolk.io>

rename CompositePropagator to CompositeHTTPPropagator, remove try/except

80c5c07

change extract/inject from class methods

6c21258

fix test to use return context

a5ca36f

remove unnecessary call to set_span_in_context

8869521

mauriciovasquezbernal reviewed Mar 5, 2020

View reviewed changes

opentelemetry-api/src/opentelemetry/propagators/composite.py Show resolved Hide resolved

mauriciovasquezbernal reviewed Mar 5, 2020

View reviewed changes

opentelemetry-api/src/opentelemetry/propagators/composite.py Outdated Show resolved Hide resolved

mauriciovasquezbernal reviewed Mar 5, 2020

View reviewed changes

opentelemetry-api/tests/propagators/test_composite.py Outdated Show resolved Hide resolved

opentelemetry-api/tests/propagators/test_composite.py Outdated Show resolved Hide resolved

Alex Boten added 2 commits March 5, 2020 12:23

removing unnecessary test, updating mock extract

a94ee8b

clean up docs

154ab5b

ocelotl approved these changes Mar 6, 2020

View reviewed changes

mauriciovasquezbernal approved these changes Mar 6, 2020

View reviewed changes

fix unused import, adding one more test

90c0535

toumorokoshi approved these changes Mar 6, 2020

View reviewed changes

toumorokoshi merged commit 9ed98eb into open-telemetry:master Mar 6, 2020

toumorokoshi mentioned this pull request Mar 16, 2020

Changelog and version updates for 0.5b0 release #498

Merged

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Implementing Propagators API to use Context #446

Implementing Propagators API to use Context #446

codeboten commented Feb 22, 2020 •

edited

Loading

codecov-io commented Feb 22, 2020 •

edited

Loading

c24t Feb 25, 2020

c24t Feb 25, 2020

toumorokoshi left a comment

toumorokoshi Feb 27, 2020

codeboten Mar 2, 2020

toumorokoshi Feb 27, 2020

codeboten Mar 4, 2020

mauriciovasquezbernal left a comment

mauriciovasquezbernal Mar 5, 2020

codeboten Mar 5, 2020

mauriciovasquezbernal left a comment

ocelotl left a comment

ocelotl Mar 6, 2020

codeboten Mar 6, 2020

mauriciovasquezbernal left a comment

toumorokoshi left a comment

toumorokoshi Mar 6, 2020

codeboten Mar 6, 2020

		logger = logging.getLogger(__name__)


		class CompositeHTTPPropagator(httptextformat.HTTPTextFormat):

Implementing Propagators API to use Context #446

Implementing Propagators API to use Context #446

Conversation

codeboten commented Feb 22, 2020 • edited Loading

codecov-io commented Feb 22, 2020 • edited Loading

Codecov Report

Choose a reason for hiding this comment

Choose a reason for hiding this comment

toumorokoshi left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

mauriciovasquezbernal left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

mauriciovasquezbernal left a comment

Choose a reason for hiding this comment

ocelotl left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

mauriciovasquezbernal left a comment

Choose a reason for hiding this comment

toumorokoshi left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

codeboten commented Feb 22, 2020 •

edited

Loading

codecov-io commented Feb 22, 2020 •

edited

Loading