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 43e6df8 commit ada006aCopy full SHA for ada006a
src/workflows/transport/middleware/tracer.py
@@ -72,6 +72,12 @@ def wrapped_callback(header, message):
72
with self.tracer.start_as_current_span(self.service_name, context=ctx) as span:
73
if ctx == {}:
74
self._inject_trace_context(message)
75
+
76
+ # Insert header and message info:
77
+ for key, value in header.items():
78
+ span.set_attribute(str(key), str(value))
79
+ for key, value in message.items():
80
81
return callback(header, message)
82
83
return call_next(channel, wrapped_callback, **kwargs)
0 commit comments