@@ -2124,38 +2124,38 @@ def get_payload_codec_with_context(
21242124 return payload_codec .with_context (workflow_context )
21252125
21262126 if command_seq in self ._pending_activities :
2127- handle = self ._pending_activities [command_seq ]
2128- context = temporalio .converter .ActivitySerializationContext (
2127+ act_handle = self ._pending_activities [command_seq ]
2128+ act_context = temporalio .converter .ActivitySerializationContext (
21292129 namespace = self ._info .namespace ,
21302130 workflow_id = self ._info .workflow_id ,
21312131 workflow_type = self ._info .workflow_type ,
2132- activity_type = handle ._input .activity ,
2132+ activity_type = act_handle ._input .activity ,
21332133 activity_task_queue = (
2134- handle ._input .task_queue
2135- if isinstance (handle ._input , StartActivityInput )
2136- and handle ._input .task_queue
2134+ act_handle ._input .task_queue
2135+ if isinstance (act_handle ._input , StartActivityInput )
2136+ and act_handle ._input .task_queue
21372137 else self ._info .task_queue
21382138 ),
2139- is_local = isinstance (handle ._input , StartLocalActivityInput ),
2139+ is_local = isinstance (act_handle ._input , StartLocalActivityInput ),
21402140 )
2141- return payload_codec .with_context (context )
2141+ return payload_codec .with_context (act_context )
21422142
21432143 elif command_seq in self ._pending_child_workflows :
2144- handle = self ._pending_child_workflows [command_seq ]
2145- context = temporalio .converter .WorkflowSerializationContext (
2144+ cwf_handle = self ._pending_child_workflows [command_seq ]
2145+ wf_context = temporalio .converter .WorkflowSerializationContext (
21462146 namespace = self ._info .namespace ,
2147- workflow_id = handle ._input .id ,
2147+ workflow_id = cwf_handle ._input .id ,
21482148 )
2149- return payload_codec .with_context (context )
2149+ return payload_codec .with_context (wf_context )
21502150
21512151 elif command_seq in self ._pending_external_signals :
21522152 # Use the target workflow's context for external signals
21532153 _ , workflow_id = self ._pending_external_signals [command_seq ]
2154- context = temporalio .converter .WorkflowSerializationContext (
2154+ wf_context = temporalio .converter .WorkflowSerializationContext (
21552155 namespace = self ._info .namespace ,
21562156 workflow_id = workflow_id ,
21572157 )
2158- return payload_codec .with_context (context )
2158+ return payload_codec .with_context (wf_context )
21592159
21602160 elif command_seq in self ._pending_nexus_operations :
21612161 # Use empty context for nexus operations: users will never want to encrypt using a
0 commit comments