Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit 10e6d2a

Browse files
authored
Fix opentracing inject to use the SpanContext, not the Span (#10074)
Signed-off-by: Brad Murray [email protected]
1 parent ed53bf3 commit 10e6d2a

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

changelog.d/10074.misc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Update opentracing to inject the right context into the carrier.

synapse/logging/opentracing.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -594,7 +594,7 @@ def inject_active_span_twisted_headers(headers, destination, check_destination=T
594594

595595
span = opentracing.tracer.active_span
596596
carrier = {} # type: Dict[str, str]
597-
opentracing.tracer.inject(span, opentracing.Format.HTTP_HEADERS, carrier)
597+
opentracing.tracer.inject(span.context, opentracing.Format.HTTP_HEADERS, carrier)
598598

599599
for key, value in carrier.items():
600600
headers.addRawHeaders(key, value)
@@ -631,7 +631,7 @@ def inject_active_span_byte_dict(headers, destination, check_destination=True):
631631
span = opentracing.tracer.active_span
632632

633633
carrier = {} # type: Dict[str, str]
634-
opentracing.tracer.inject(span, opentracing.Format.HTTP_HEADERS, carrier)
634+
opentracing.tracer.inject(span.context, opentracing.Format.HTTP_HEADERS, carrier)
635635

636636
for key, value in carrier.items():
637637
headers[key.encode()] = [value.encode()]
@@ -665,7 +665,7 @@ def inject_active_span_text_map(carrier, destination, check_destination=True):
665665
return
666666

667667
opentracing.tracer.inject(
668-
opentracing.tracer.active_span, opentracing.Format.TEXT_MAP, carrier
668+
opentracing.tracer.active_span.context, opentracing.Format.TEXT_MAP, carrier
669669
)
670670

671671

@@ -687,7 +687,7 @@ def get_active_span_text_map(destination=None):
687687

688688
carrier = {} # type: Dict[str, str]
689689
opentracing.tracer.inject(
690-
opentracing.tracer.active_span, opentracing.Format.TEXT_MAP, carrier
690+
opentracing.tracer.active_span.context, opentracing.Format.TEXT_MAP, carrier
691691
)
692692

693693
return carrier
@@ -702,7 +702,7 @@ def active_span_context_as_string():
702702
carrier = {} # type: Dict[str, str]
703703
if opentracing:
704704
opentracing.tracer.inject(
705-
opentracing.tracer.active_span, opentracing.Format.TEXT_MAP, carrier
705+
opentracing.tracer.active_span.context, opentracing.Format.TEXT_MAP, carrier
706706
)
707707
return json_encoder.encode(carrier)
708708

0 commit comments

Comments
 (0)