diff --git a/tests/nexus/test_temporal_operation.py b/tests/nexus/test_temporal_operation.py index f23728d17..1fa7e0c3e 100644 --- a/tests/nexus/test_temporal_operation.py +++ b/tests/nexus/test_temporal_operation.py @@ -658,6 +658,10 @@ async def run_update(i: int) -> str: async def check_updates_on_completed_workflows_fail(): """The handler workflow already finished at this point, further updaes should just fail""" + # The last update's result does not mean the target has closed yet. + # An update that lands before the closure stays pending instead of + # failing. + await target_handle.result() wf_handle = await client.start_workflow( UpdateWorkflowCaller.run, Input(