We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0e496ed commit 5e3ff7cCopy full SHA for 5e3ff7c
src/workflows/transport/middleware/tracer.py
@@ -42,14 +42,13 @@ def _initiate_tracers(self, service_name):
42
43
def _extract_trace_context(self, message):
44
"""Retrieves Context object from message"""
45
- try:
+ carrier = message.get('trace_context')
46
+ if carrier:
47
# Deserialise serialised context into a Context object:
- carrier = message['trace_context']
48
ctx = TraceContextTextMapPropagator().extract(carrier=carrier)
49
return ctx
50
- except KeyError:
51
- # If no context, leave empty:
52
- return {}
+ # If no context, leave empty:
+ return {}
53
54
def _inject_trace_context(self, message):
55
"""Inserts serialized trace context into message"""
0 commit comments