@@ -27,7 +27,6 @@ class B3Format(HTTPTextFormat):
27
27
SINGLE_HEADER_KEY = "b3"
28
28
TRACE_ID_KEY = "x-b3-traceid"
29
29
SPAN_ID_KEY = "x-b3-spanid"
30
- PARENT_SPAN_ID_KEY = "x-b3-parentspanid"
31
30
SAMPLED_KEY = "x-b3-sampled"
32
31
FLAGS_KEY = "x-b3-flags"
33
32
_SAMPLE_PROPAGATE_VALUES = set (["1" , "True" , "true" , "d" ])
@@ -36,7 +35,6 @@ class B3Format(HTTPTextFormat):
36
35
def extract (cls , get_from_carrier , carrier ):
37
36
trace_id = format_trace_id (trace .INVALID_TRACE_ID )
38
37
span_id = format_span_id (trace .INVALID_SPAN_ID )
39
- parent_span_id = format_span_id (trace .INVALID_SPAN_ID )
40
38
sampled = "0"
41
39
flags = None
42
40
@@ -57,7 +55,7 @@ def extract(cls, get_from_carrier, carrier):
57
55
elif len (fields ) == 3 :
58
56
trace_id , span_id , sampled = fields
59
57
elif len (fields ) == 4 :
60
- trace_id , span_id , sampled , parent_span_id = fields
58
+ trace_id , span_id , sampled , _parent_span_id = fields
61
59
else :
62
60
return trace .INVALID_SPAN_CONTEXT
63
61
else :
@@ -73,12 +71,6 @@ def extract(cls, get_from_carrier, carrier):
73
71
)
74
72
or span_id
75
73
)
76
- parent_span_id = (
77
- _extract_first_element (
78
- get_from_carrier (carrier , cls .PARENT_SPAN_ID_KEY )
79
- )
80
- or parent_span_id
81
- )
82
74
sampled = (
83
75
_extract_first_element (
84
76
get_from_carrier (carrier , cls .SAMPLED_KEY )
@@ -99,22 +91,12 @@ def extract(cls, get_from_carrier, carrier):
99
91
# header is set to allow.
100
92
if sampled in cls ._SAMPLE_PROPAGATE_VALUES or flags == "1" :
101
93
options |= trace .TraceOptions .SAMPLED
102
-
103
- trace_state = trace .TraceState ()
104
-
105
- if parent_span_id != trace .INVALID_SPAN_ID :
106
- # FIXME This is a workaround for the error specified below being
107
- # raised because of a pylint issue. Remove this when the issue is
108
- # fixed in pylint.
109
- # pylint: disable=E1137
110
- trace_state [cls .PARENT_SPAN_ID_KEY ] = int (parent_span_id , 16 )
111
-
112
94
return trace .SpanContext (
113
95
# trace an span ids are encoded in hex, so must be converted
114
96
trace_id = int (trace_id , 16 ),
115
97
span_id = int (span_id , 16 ),
116
98
trace_options = trace .TraceOptions (options ),
117
- trace_state = trace_state ,
99
+ trace_state = trace . TraceState () ,
118
100
)
119
101
120
102
@classmethod
@@ -126,11 +108,6 @@ def inject(cls, context, set_in_carrier, carrier):
126
108
set_in_carrier (
127
109
carrier , cls .SPAN_ID_KEY , format_span_id (context .span_id )
128
110
)
129
- set_in_carrier (
130
- carrier ,
131
- cls .PARENT_SPAN_ID_KEY ,
132
- format_span_id (context .trace_state [cls .PARENT_SPAN_ID_KEY ]),
133
- )
134
111
set_in_carrier (carrier , cls .SAMPLED_KEY , "1" if sampled else "0" )
135
112
136
113
0 commit comments