File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 4444# See https://github.com/temporalio/sdk-python/issues/1704.
4545pytestmark = pytest .mark .requires_local_server
4646
47+ # Query response links require a newer server than the shared test environment.
48+ _QUERY_LINK_DEV_SERVER_DOWNLOAD_VERSION = "v1.8.3-server-1.32.0-162.0"
49+
4750
4851@dataclass
4952class Input :
@@ -851,7 +854,14 @@ async def run(self, input: Input) -> bool:
851854 return await client .execute_operation (TestService .query_op , input .value )
852855
853856
854- async def test_temporal_operation_query_workflow (
857+ async def test_temporal_operation_query_workflow () -> None :
858+ async with await WorkflowEnvironment .start_local (
859+ dev_server_download_version = _QUERY_LINK_DEV_SERVER_DOWNLOAD_VERSION
860+ ) as env :
861+ await _assert_temporal_operation_query_workflow (env .client , env )
862+
863+
864+ async def _assert_temporal_operation_query_workflow (
855865 client : Client , env : WorkflowEnvironment
856866) -> None :
857867 task_queue = str (uuid .uuid4 ())
@@ -890,8 +900,6 @@ async def test_temporal_operation_query_workflow(
890900 target_history = await target_handle .fetch_history ()
891901 assert not any (event .links for event in target_history .events )
892902
893- if not completed_event .links :
894- pytest .skip ("server did not return a Workflow Query response link" )
895903 assert target_handle .result_run_id is not None
896904 assert Link (
897905 workflow = Link .Workflow (
You can’t perform that action at this time.
0 commit comments