Preserve lifecycle reasons in test backend

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>

Copilot-Session: 941fc052-b910-42af-93fa-4f00138813ab

Author: andystaples

.github/copilot-instructions.md

@@ -224,3 +224,17 @@ works correctly:
 - If a new public API is added to the core SDK (e.g. a method on
   `OrchestrationContext`), confirm it is accessible through the
   azuremanaged package and add a test or example if appropriate.
+
+## Release Coordination
+
+- Package versions and inter-package minimum dependencies record the latest
+  released compatibility contract. They are not an instruction to bump versions
+  in a feature PR.
+- When a core `durabletask` API is consumed by `durabletask.azuremanaged` or
+  `azure-functions-durable`, do not update package versions or dependency
+  minimums in the feature PR. Document the affected package changelogs and
+  release coordination instead.
+- Create a dedicated release PR after the core package has been released. It
+  must publish `durabletask` first, then update provider dependency minimums,
+  package versions, and release notes so resolvers cannot select a provider
+  release with an incompatible older core package.

azure-functions-durable/CHANGELOG.md

@@ -7,6 +7,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## Unreleased
 
+> [!NOTE]
+> Release this change only in coordination with a new `durabletask` release
+> that contains the suspend/resume reason APIs. Publish `durabletask` first,
+> then update this package's minimum dependency in its dedicated release PR.
+
 FIXED
 
 - Fixed deprecated `DurableFunctionsClient.suspend()` and `resume()` methods

durabletask-azuremanaged/CHANGELOG.md

@@ -7,6 +7,11 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## Unreleased
 
+ADDED
+
+- Added optional `reason` parameters to suspend and resume operations inherited
+from `TaskHubGrpcClient` and `AsyncTaskHubGrpcClient`.
+
 ## v1.9.0
 
 CHANGED

durabletask/internal/helpers.py

@@ -234,19 +234,23 @@ def new_event_raised_event(name: str, encoded_input: str | None = None) -> pb.Hi
     )
 
 
-def new_suspend_event() -> pb.HistoryEvent:
+def new_suspend_event(*, encoded_input: str | None = None) -> pb.HistoryEvent:
     return pb.HistoryEvent(
         eventId=-1,
         timestamp=timestamp_pb2.Timestamp(),
-        executionSuspended=pb.ExecutionSuspendedEvent()
+        executionSuspended=pb.ExecutionSuspendedEvent(
+            input=get_string_value(encoded_input)
+        )
     )
 
 
-def new_resume_event() -> pb.HistoryEvent:
+def new_resume_event(*, encoded_input: str | None = None) -> pb.HistoryEvent:
     return pb.HistoryEvent(
         eventId=-1,
         timestamp=timestamp_pb2.Timestamp(),
-        executionResumed=pb.ExecutionResumedEvent()
+        executionResumed=pb.ExecutionResumedEvent(
+            input=get_string_value(encoded_input)
+        )
     )
 
 

durabletask/testing/in_memory_backend.py

@@ -386,7 +386,9 @@ def SuspendInstance(self, request: pb.SuspendRequest, context: grpc.ServicerCont
             if instance.status == pb.ORCHESTRATION_STATUS_SUSPENDED:
                 return pb.SuspendResponse()
 
-            event = helpers.new_suspend_event()
+            event = helpers.new_suspend_event(
+                encoded_input=request.reason.value if request.HasField("reason") else None
+            )
             instance.pending_events.append(event)
             instance.last_updated_at = datetime.now(timezone.utc)
             self._enqueue_orchestration(instance.instance_id)
@@ -403,7 +405,9 @@ def ResumeInstance(self, request: pb.ResumeRequest, context: grpc.ServicerContex
                               f"Orchestration instance '{request.instanceId}' not found")
                 return pb.ResumeResponse()
 
-            event = helpers.new_resume_event()
+            event = helpers.new_resume_event(
+                encoded_input=request.reason.value if request.HasField("reason") else None
+            )
             instance.pending_events.append(event)
             instance.last_updated_at = datetime.now(timezone.utc)
             self._enqueue_orchestration(instance.instance_id)

tests/durabletask/test_orchestration_e2e.py

@@ -275,7 +275,7 @@ def orchestrator(ctx: task.OrchestrationContext, _):
         assert state.serialized_output == json.dumps("timed out")
 
 
-def test_suspend_and_resume():
+def test_suspend_and_resume_preserves_reasons_in_history():
     def orchestrator(ctx: task.OrchestrationContext, _):
         result = yield ctx.wait_for_external_event("my_event")
         return result
@@ -290,7 +290,7 @@ def orchestrator(ctx: task.OrchestrationContext, _):
             assert state is not None
 
             # Suspend the orchestration and wait for it to go into the SUSPENDED state
-            task_hub_client.suspend_orchestration(id)
+            task_hub_client.suspend_orchestration(id, reason="maintenance")
             deadline = time.time() + 10
             while state.runtime_status == client.OrchestrationStatus.RUNNING:
                 assert time.time() < deadline, "Timed out waiting for SUSPENDED status"
@@ -308,11 +308,18 @@ def orchestrator(ctx: task.OrchestrationContext, _):
                 pass
 
             # Resume the orchestration and wait for it to complete
-            task_hub_client.resume_orchestration(id)
+            task_hub_client.resume_orchestration(id, reason="maintenance complete")
             state = task_hub_client.wait_for_orchestration_completion(id, timeout=30)
+            events = task_hub_client.get_orchestration_history(id)
             assert state is not None
             assert state.runtime_status == client.OrchestrationStatus.COMPLETED
             assert state.serialized_output == json.dumps(42)
+            suspended_event = next(
+                event for event in events if isinstance(event, history.ExecutionSuspendedEvent))
+            resumed_event = next(
+                event for event in events if isinstance(event, history.ExecutionResumedEvent))
+            assert suspended_event.input == "maintenance"
+            assert resumed_event.input == "maintenance complete"
 
 
 def test_terminate():