remove context activate in handler

Signed-off-by: Tim Li <[email protected]>

Author: timl3136

cadence/worker/_decision_task_handler.py

@@ -87,20 +87,11 @@ async def _handle_task_implementation(self, task: PollForDecisionTaskResponse) -
 
         # Create workflow context and execute with it active
         workflow_engine = self._workflow_engines[engine_key]
-        workflow_info = WorkflowInfo(
-            workflow_type=workflow_type_name,
-            workflow_domain=self._client.domain,
-            workflow_id=workflow_id,
-            workflow_run_id=run_id
-        )
 
-        context = Context(client=self._client, info=workflow_info)
-        with context._activate():
-            # Process the decision using the workflow engine
-            decision_result = await workflow_engine.process_decision(task)
-            
-            # Respond with the decisions
-            await self._respond_decision_task_completed(task, decision_result)
+        decision_result = await workflow_engine.process_decision(task)
+        
+        # Respond with the decisions
+        await self._respond_decision_task_completed(task, decision_result)
 
         logger.info(f"Successfully processed decision task for workflow {workflow_id}")
 

tests/cadence/worker/test_decision_task_handler.py

@@ -322,8 +322,8 @@ async def test_workflow_engine_creation_with_workflow_info(self, handler, sample
             with patch('cadence.worker._decision_task_handler.WorkflowInfo') as mock_workflow_info_class:
                 await handler._handle_task_implementation(sample_decision_task)
 
-                # Verify WorkflowInfo was created with correct parameters (called twice - once for engine, once for context)
-                assert mock_workflow_info_class.call_count == 2
+                # Verify WorkflowInfo was created with correct parameters (called once for engine)
+                assert mock_workflow_info_class.call_count == 1
                 for call in mock_workflow_info_class.call_args_list:
                     assert call[1] == {
                         'workflow_type': "TestWorkflow",