File tree 3 files changed +6
-10
lines changed
instrumentation/opentelemetry-instrumentation-asgi/src/opentelemetry/instrumentation/asgi
sdk-extension/opentelemetry-sdk-extension-aws/tests
performance/benchmarks/trace/propagation
3 files changed +6
-10
lines changed Original file line number Diff line number Diff line change 29
29
from opentelemetry .instrumentation .asgi .version import __version__ # noqa
30
30
from opentelemetry .instrumentation .utils import http_status_to_status_code
31
31
from opentelemetry .propagate import extract
32
- from opentelemetry .propagators .textmap import CarrierT , Getter
32
+ from opentelemetry .propagators .textmap import Getter
33
33
from opentelemetry .trace .status import Status , StatusCode
34
34
35
35
36
36
class ASGIGetter (Getter ):
37
37
def get (
38
- self , carrier : CarrierT , key : str
38
+ self , carrier : dict , key : str
39
39
) -> typing .Optional [typing .List [str ]]:
40
40
"""Getter implementation to retrieve a HTTP header value from the ASGI
41
41
scope.
@@ -62,7 +62,7 @@ def get(
62
62
return None
63
63
return decoded
64
64
65
- def keys (self , carrier : CarrierT ) -> typing .List [str ]:
65
+ def keys (self , carrier : dict ) -> typing .List [str ]:
66
66
return list (carrier .keys ())
67
67
68
68
Original file line number Diff line number Diff line change @@ -33,7 +33,5 @@ def test_extract_single_header(benchmark):
33
33
34
34
def test_inject_empty_context (benchmark ):
35
35
benchmark (
36
- XRAY_PROPAGATOR .inject ,
37
- {},
38
- setter = CaseInsensitiveDict .__setitem__
36
+ XRAY_PROPAGATOR .inject , {}, setter = CaseInsensitiveDict .__setitem__
39
37
)
Original file line number Diff line number Diff line change @@ -92,8 +92,7 @@ def test_inject_into_non_sampled_context(self):
92
92
carrier = CaseInsensitiveDict ()
93
93
94
94
AwsXRayPropagatorTest .XRAY_PROPAGATOR .inject (
95
- carrier ,
96
- build_test_current_context (),
95
+ carrier , build_test_current_context (),
97
96
)
98
97
99
98
injected_items = set (carrier .items ())
@@ -154,8 +153,7 @@ def test_inject_reported_fields_matches_carrier_fields(self):
154
153
carrier = CaseInsensitiveDict ()
155
154
156
155
AwsXRayPropagatorTest .XRAY_PROPAGATOR .inject (
157
- carrier ,
158
- build_test_current_context (),
156
+ carrier , build_test_current_context (),
159
157
)
160
158
161
159
injected_keys = set (carrier .keys ())
You can’t perform that action at this time.
0 commit comments