15
15
from unittest import TestCase
16
16
17
17
from opentelemetry .baggage import get_all , set_baggage
18
- from opentelemetry .propagator .opentracing import (
18
+ from opentelemetry .propagator .ot_trace import (
19
19
OT_BAGGAGE_PREFIX ,
20
20
OT_SAMPLED_HEADER ,
21
21
OT_SPAN_ID_HEADER ,
22
22
OT_TRACE_ID_HEADER ,
23
- OpenTracingPropagator ,
23
+ OTTracePropagator ,
24
24
)
25
25
from opentelemetry .sdk .trace import _Span
26
26
from opentelemetry .trace import (
37
37
carrier_getter = DictGetter ()
38
38
39
39
40
- class TestOpenTracingPropagator (TestCase ):
40
+ class TestOTTracePropagator (TestCase ):
41
41
42
- opentracing_propagator = OpenTracingPropagator ()
42
+ ot_trace_propagator = OTTracePropagator ()
43
43
44
44
def carrier_inject (self , trace_id , span_id , is_remote , trace_flags ):
45
45
46
46
carrier = {}
47
47
48
- self .opentracing_propagator .inject (
48
+ self .ot_trace_propagator .inject (
49
49
dict .__setitem__ ,
50
50
carrier ,
51
51
set_span_in_context (
@@ -146,7 +146,7 @@ def test_inject_set_baggage(self):
146
146
147
147
carrier = {}
148
148
149
- self .opentracing_propagator .inject (
149
+ self .ot_trace_propagator .inject (
150
150
dict .__setitem__ ,
151
151
carrier ,
152
152
set_baggage (
@@ -175,7 +175,7 @@ def test_inject_invalid_baggage_keys(self):
175
175
176
176
carrier = {}
177
177
178
- self .opentracing_propagator .inject (
178
+ self .ot_trace_propagator .inject (
179
179
dict .__setitem__ ,
180
180
carrier ,
181
181
set_baggage (
@@ -204,7 +204,7 @@ def test_inject_invalid_baggage_values(self):
204
204
205
205
carrier = {}
206
206
207
- self .opentracing_propagator .inject (
207
+ self .ot_trace_propagator .inject (
208
208
dict .__setitem__ ,
209
209
carrier ,
210
210
set_baggage (
@@ -232,7 +232,7 @@ def test_extract_trace_id_span_id_sampled_true(self):
232
232
"""Test valid trace_id, span_id and sampled true"""
233
233
234
234
span_context = get_current_span (
235
- self .opentracing_propagator .extract (
235
+ self .ot_trace_propagator .extract (
236
236
carrier_getter ,
237
237
{
238
238
OT_TRACE_ID_HEADER : "80f198ee56343ba864fe8b2a57d3eff7" ,
@@ -253,7 +253,7 @@ def test_extract_trace_id_span_id_sampled_false(self):
253
253
"""Test valid trace_id, span_id and sampled false"""
254
254
255
255
span_context = get_current_span (
256
- self .opentracing_propagator .extract (
256
+ self .ot_trace_propagator .extract (
257
257
carrier_getter ,
258
258
{
259
259
OT_TRACE_ID_HEADER : "80f198ee56343ba864fe8b2a57d3eff7" ,
@@ -274,7 +274,7 @@ def test_extract_malformed_trace_id(self):
274
274
"""Test extraction with malformed trace_id"""
275
275
276
276
span_context = get_current_span (
277
- self .opentracing_propagator .extract (
277
+ self .ot_trace_propagator .extract (
278
278
carrier_getter ,
279
279
{
280
280
OT_TRACE_ID_HEADER : "abc123" ,
@@ -290,7 +290,7 @@ def test_extract_malformed_span_id(self):
290
290
"""Test extraction with malformed span_id"""
291
291
292
292
span_context = get_current_span (
293
- self .opentracing_propagator .extract (
293
+ self .ot_trace_propagator .extract (
294
294
carrier_getter ,
295
295
{
296
296
OT_TRACE_ID_HEADER : "64fe8b2a57d3eff7" ,
@@ -306,7 +306,7 @@ def test_extract_invalid_trace_id(self):
306
306
"""Test extraction with invalid trace_id"""
307
307
308
308
span_context = get_current_span (
309
- self .opentracing_propagator .extract (
309
+ self .ot_trace_propagator .extract (
310
310
carrier_getter ,
311
311
{
312
312
OT_TRACE_ID_HEADER : INVALID_TRACE_ID ,
@@ -322,7 +322,7 @@ def test_extract_invalid_span_id(self):
322
322
"""Test extraction with invalid span_id"""
323
323
324
324
span_context = get_current_span (
325
- self .opentracing_propagator .extract (
325
+ self .ot_trace_propagator .extract (
326
326
carrier_getter ,
327
327
{
328
328
OT_TRACE_ID_HEADER : "64fe8b2a57d3eff7" ,
@@ -337,7 +337,7 @@ def test_extract_invalid_span_id(self):
337
337
def test_extract_baggage (self ):
338
338
"""Test baggage extraction"""
339
339
340
- context = self .opentracing_propagator .extract (
340
+ context = self .ot_trace_propagator .extract (
341
341
carrier_getter ,
342
342
{
343
343
OT_TRACE_ID_HEADER : "64fe8b2a57d3eff7" ,
0 commit comments