Skip to content

Commit dd2e34a

Browse files
Fixing time-skipping test error
1 parent 52491fb commit dd2e34a

1 file changed

Lines changed: 11 additions & 9 deletions

File tree

‎tests/nexus/test_temporal_operation.py‎

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -890,15 +890,17 @@ async def test_temporal_operation_query_workflow(
890890
target_history = await target_handle.fetch_history()
891891
assert not any(event.links for event in target_history.events)
892892

893-
assert target_handle.result_run_id is not None
894-
assert Link(
895-
workflow=Link.Workflow(
896-
namespace=client.namespace,
897-
workflow_id=target_workflow_id,
898-
run_id=target_handle.result_run_id,
899-
reason="Query processed",
900-
)
901-
) in list(completed_event.links)
893+
# The Java time-skipping test server does not return Nexus operation links.
894+
if not env.supports_time_skipping:
895+
assert target_handle.result_run_id is not None
896+
assert Link(
897+
workflow=Link.Workflow(
898+
namespace=client.namespace,
899+
workflow_id=target_workflow_id,
900+
run_id=target_handle.result_run_id,
901+
reason="Query processed",
902+
)
903+
) in list(completed_event.links)
902904
finally:
903905
await target_handle.cancel()
904906

0 commit comments

Comments
 (0)