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 767228b commit 2d41030Copy full SHA for 2d41030
temporalio/contrib/opentelemetry.py
@@ -307,10 +307,12 @@ async def start_update_with_start_workflow(
307
input=input.start_workflow_input,
308
kind=opentelemetry.trace.SpanKind.CLIENT,
309
):
310
- if input.update_workflow_input:
311
- input.update_workflow_input.headers = self.root._context_to_headers(
312
- input.update_workflow_input.headers
313
- )
+ otel_header = input.start_workflow_input.headers.get(self.root.header_key)
+ if otel_header:
+ input.update_workflow_input.headers = {
+ **input.update_workflow_input.headers,
314
+ self.root.header_key: otel_header,
315
+ }
316
317
return await super().start_update_with_start_workflow(input)
318
0 commit comments