Skip to content

Commit 5f03401

Browse files
committed
Add future resolutuion to output
1 parent 3066ea0 commit 5f03401

File tree

2 files changed

+20
-2
lines changed

2 files changed

+20
-2
lines changed

tests/nexus/test_workflow_caller_cancellation_types.py

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -331,7 +331,16 @@ async def check_behavior_for_try_cancel(
331331
assert handler_status == WorkflowExecutionStatus.CANCELED
332332
caller_op_future_resolved = test_context.caller_op_future_resolved.result()
333333

334-
await print_interleaved_histories([caller_wf, handler_wf])
334+
await print_interleaved_histories(
335+
[caller_wf, handler_wf],
336+
extra_events=[
337+
(
338+
caller_wf,
339+
"Caller op future resolved",
340+
caller_op_future_resolved,
341+
)
342+
],
343+
)
335344

336345
await assert_event_subsequence(
337346
[

tests/nexus/test_workflow_caller_cancellation_types_when_cancel_handler_fails.py

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -302,7 +302,16 @@ async def check_behavior_for_try_cancel(
302302
assert result.error_cause_type == "CancelledError"
303303

304304
caller_op_future_resolved = test_context.caller_op_future_resolved.result()
305-
await print_interleaved_histories([caller_wf, handler_wf])
305+
await print_interleaved_histories(
306+
[caller_wf, handler_wf],
307+
extra_events=[
308+
(
309+
caller_wf,
310+
"Caller op future resolved",
311+
caller_op_future_resolved,
312+
)
313+
],
314+
)
306315

307316
await assert_event_subsequence(
308317
[

0 commit comments

Comments
 (0)