Merge upstream/main into signal_decorator

Resolved conflicts:
- Kept signal decorator functionality from signal_decorator branch
- Adopted frozen=True convention for WorkflowInfo from upstream
- Removed test_workflow_engine_integration.py as upstream reorganized tests

Author: timl3136

cadence/_internal/workflow/context.py

@@ -1,6 +1,7 @@
+from contextlib import contextmanager
 from datetime import timedelta
 from math import ceil
-from typing import Optional, Any, Unpack, Type, cast
+from typing import Iterator, Optional, Any, Unpack, Type, cast
 
 from cadence._internal.workflow.statemachine.decision_manager import DecisionManager
 from cadence._internal.workflow.decisions_helper import DecisionsHelper
@@ -15,13 +16,12 @@ class Context(WorkflowContext):
     def __init__(
         self,
         info: WorkflowInfo,
-        decision_helper: DecisionsHelper,
         decision_manager: DecisionManager,
     ):
         self._info = info
         self._replay_mode = True
         self._replay_current_time_milliseconds: Optional[int] = None
-        self._decision_helper = decision_helper
+        self._decision_helper = DecisionsHelper()
         self._decision_manager = decision_manager
 
     def info(self) -> WorkflowInfo:
@@ -110,6 +110,12 @@ def get_replay_current_time_milliseconds(self) -> Optional[int]:
         """Get the current replay time in milliseconds."""
         return self._replay_current_time_milliseconds
 
+    @contextmanager
+    def _activate(self) -> Iterator["Context"]:
+        token = WorkflowContext._var.set(self)
+        yield self
+        WorkflowContext._var.reset(token)
+
 
 def _round_to_nearest_second(delta: timedelta) -> timedelta:
     return timedelta(seconds=ceil(delta.total_seconds()))

cadence/_internal/workflow/decision_events_iterator.py

@@ -11,7 +11,6 @@
 
 from cadence._internal.workflow.history_event_iterator import HistoryEventsIterator
 from cadence.api.v1.history_pb2 import HistoryEvent
-from cadence.api.v1.service_worker_pb2 import PollForDecisionTaskResponse
 
 
 @dataclass
@@ -44,10 +43,8 @@ class DecisionEventsIterator(Iterator[DecisionEvents]):
 
     def __init__(
         self,
-        decision_task: PollForDecisionTaskResponse,
         events: List[HistoryEvent],
     ):
-        self._decision_task = decision_task
         self._events: HistoryEventsIterator = HistoryEventsIterator(events)
         self._next_decision_event_id: Optional[int] = None
         self._replay_current_time_milliseconds: Optional[int] = None