Revert changes to client as they are unecessary. Inject otel headers into both operation inputs in otel interceptor

Author: VegetarianOrc

temporalio/client.py

@@ -1208,7 +1208,6 @@ def on_start_error(
             start_workflow_input=start_workflow_operation._start_workflow_input,
             update_workflow_input=update_input,
             _on_start=on_start,
-            headers={},
             _on_start_error=on_start_error,
         )
 
@@ -5539,7 +5538,6 @@ class StartWorkflowUpdateWithStartInput:
         [temporalio.api.workflowservice.v1.StartWorkflowExecutionResponse], None
     ]
     _on_start_error: Callable[[BaseException], None]
-    headers: Mapping[str, temporalio.api.common.v1.Payload]
 
 
 @dataclass
@@ -6363,10 +6361,6 @@ def on_start(
 
         err: Optional[BaseException] = None
 
-        # fan headers out to both operations
-        input.start_workflow_input.headers = input.headers
-        input.update_workflow_input.headers = input.headers
-
         try:
             return await self._start_workflow_update_with_start(
                 input.start_workflow_input, input.update_workflow_input, on_start

temporalio/contrib/opentelemetry.py

@@ -304,9 +304,14 @@ async def start_update_with_start_workflow(
         with self.root._start_as_current_span(
             f"StartUpdateWithStartWorkflow:{input.start_workflow_input.workflow}",
             attributes=attrs,
-            input=input,
+            input=input.start_workflow_input,
             kind=opentelemetry.trace.SpanKind.CLIENT,
         ):
+            if input.update_workflow_input:
+                input.update_workflow_input.headers = self.root._context_to_headers(
+                    input.update_workflow_input.headers
+                )
+
             return await super().start_update_with_start_workflow(input)