Add debug output

Author: dandavison

tests/nexus/test_workflow_caller_cancellation_types.py

@@ -21,6 +21,7 @@
 from temporalio.common import WorkflowIDConflictPolicy
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
+from tests.helpers import print_interleaved_histories
 from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
 
 
@@ -420,6 +421,13 @@ async def check_behavior_for_wait_cancellation_completed(
     await caller_wf.signal(CallerWorkflow.release)
     result = await caller_wf.result()
 
+    await print_interleaved_histories(
+        [caller_wf, handler_wf],
+        extra_events=[
+            (caller_wf, "op future resolved", result.caller_op_future_resolved),
+        ],
+    )
+
     await assert_event_subsequence(
         [
             (caller_wf, EventType.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED),

tests/nexus/test_workflow_caller_cancellation_types_when_cancel_handler_fails.py

@@ -23,6 +23,7 @@
 from temporalio.common import WorkflowIDConflictPolicy
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
+from tests.helpers import print_interleaved_histories
 from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
 from tests.nexus.test_workflow_caller_cancellation_types import (
     assert_event_subsequence,
@@ -362,6 +363,14 @@ async def check_behavior_for_wait_cancellation_completed(
     await handler_wf.result()
     await caller_wf.signal(CallerWorkflow.release)
     result = await caller_wf.result()
+
+    await print_interleaved_histories(
+        [caller_wf, handler_wf],
+        extra_events=[
+            (caller_wf, "op future resolved", result.caller_op_future_resolved),
+        ],
+    )
+
     assert not result.error_type
     # Note that the relative order of these two events is non-deterministic, since one is the result
     # of the cancel handler response being processed and the other is the result of the handler