From 136444c391a322933e587fa3d0ecfe681d82233b Mon Sep 17 00:00:00 2001 From: Quinn Klassen Date: Mon, 23 Feb 2026 13:55:46 -0800 Subject: [PATCH 1/5] Stop skipping some Nexus tests --- tests/nexus/test_workflow_caller.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/tests/nexus/test_workflow_caller.py b/tests/nexus/test_workflow_caller.py index 70417625d..44462afba 100644 --- a/tests/nexus/test_workflow_caller.py +++ b/tests/nexus/test_workflow_caller.py @@ -593,8 +593,6 @@ async def run(self, input: WorkflowRunHeaderTestCallerWfInput) -> HeaderTestOutp async def test_sync_operation_happy_path(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") task_queue = str(uuid.uuid4()) async with Worker( client, @@ -631,8 +629,6 @@ async def test_sync_operation_happy_path(client: Client, env: WorkflowEnvironmen async def test_workflow_run_operation_happy_path( client: Client, env: WorkflowEnvironment ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") task_queue = str(uuid.uuid4()) async with Worker( client, From 2ee44232da51dc83f115aaaf8b31f01daec47f54 Mon Sep 17 00:00:00 2001 From: Quinn Klassen Date: Mon, 23 Feb 2026 15:10:19 -0800 Subject: [PATCH 2/5] Enable more tests --- .../test_use_existing_conflict_policy.py | 3 --- tests/nexus/test_workflow_caller.py | 26 ------------------- ...test_workflow_caller_cancellation_types.py | 3 --- 3 files changed, 32 deletions(-) diff --git a/tests/nexus/test_use_existing_conflict_policy.py b/tests/nexus/test_use_existing_conflict_policy.py index 95925ded0..8c8ad6a39 100644 --- a/tests/nexus/test_use_existing_conflict_policy.py +++ b/tests/nexus/test_use_existing_conflict_policy.py @@ -91,9 +91,6 @@ async def nexus_operations_have_started(self) -> None: async def test_multiple_operation_invocations_can_connect_to_same_handler_workflow( client: Client, env: WorkflowEnvironment ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) workflow_id = str(uuid.uuid4()) diff --git a/tests/nexus/test_workflow_caller.py b/tests/nexus/test_workflow_caller.py index 44462afba..27fb208b0 100644 --- a/tests/nexus/test_workflow_caller.py +++ b/tests/nexus/test_workflow_caller.py @@ -829,9 +829,6 @@ async def test_workflow_run_operation_headers( env: WorkflowEnvironment, ): """Test that headers are propagated to @workflow_run_operation handlers.""" - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) test_headers = {"x-custom-workflow-run": "workflow-run-value"} @@ -862,8 +859,6 @@ async def test_cancel_operation_headers( env: WorkflowEnvironment, ): """Test headers from workflow and interceptor are propagated to cancel operation handler.""" - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") task_queue = str(uuid.uuid4()) workflow_id = str(uuid.uuid4()) @@ -1313,9 +1308,6 @@ async def run( async def test_service_interface_and_implementation_names( client: Client, env: WorkflowEnvironment ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - # Note that: # - The caller can specify the service & operation via a reference to either the # interface or implementation class. @@ -1444,9 +1436,6 @@ async def test_workflow_run_operation_can_execute_workflow_before_starting_backi client: Client, env: WorkflowEnvironment, ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) async with Worker( client, @@ -1500,9 +1489,6 @@ async def test_nexus_operation_summary( client: Client, env: WorkflowEnvironment, ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = f"task-queue-{uuid.uuid4()}" async with Worker( client, @@ -1795,9 +1781,6 @@ async def run(self, op: str, input: OverloadTestValue) -> OverloadTestValue: async def test_workflow_run_operation_overloads( client: Client, env: WorkflowEnvironment, op: str ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) async with Worker( client, @@ -1866,9 +1849,6 @@ async def run(self, task_queue: str) -> None: async def test_workflow_caller_custom_metrics(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) endpoint_name = make_nexus_endpoint_name(task_queue) await env.create_nexus_endpoint(endpoint_name, task_queue) @@ -1945,9 +1925,6 @@ async def test_workflow_caller_custom_metrics(client: Client, env: WorkflowEnvir async def test_workflow_caller_buffered_metrics( client: Client, env: WorkflowEnvironment ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - # Create runtime with metric buffer buffer = MetricBuffer(10000) runtime = Runtime( @@ -2127,9 +2104,6 @@ async def test_task_executor_operation_cancel_method( self, client: Client, env: WorkflowEnvironment, use_async_cancel: bool ): """Test that both async and non-async cancel methods work for TaskExecutor-based operations.""" - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - task_queue = str(uuid.uuid4()) async with Worker( client, diff --git a/tests/nexus/test_workflow_caller_cancellation_types.py b/tests/nexus/test_workflow_caller_cancellation_types.py index 9cbb95e77..6ebba5759 100644 --- a/tests/nexus/test_workflow_caller_cancellation_types.py +++ b/tests/nexus/test_workflow_caller_cancellation_types.py @@ -238,9 +238,6 @@ async def test_cancellation_type( env: WorkflowEnvironment, cancellation_type_name: str, ): - if env.supports_time_skipping: - pytest.skip("Nexus tests don't work with time-skipping server") - cancellation_type = workflow.NexusOperationCancellationType[cancellation_type_name] global test_context test_context = TestContext( From 3233cfa72d06a9573a1efd12198704ab77786d77 Mon Sep 17 00:00:00 2001 From: Quinn Klassen Date: Mon, 23 Feb 2026 15:13:59 -0800 Subject: [PATCH 3/5] Fix lint error --- tests/nexus/test_use_existing_conflict_policy.py | 1 - 1 file changed, 1 deletion(-) diff --git a/tests/nexus/test_use_existing_conflict_policy.py b/tests/nexus/test_use_existing_conflict_policy.py index 8c8ad6a39..e7cee9e1c 100644 --- a/tests/nexus/test_use_existing_conflict_policy.py +++ b/tests/nexus/test_use_existing_conflict_policy.py @@ -4,7 +4,6 @@ import uuid from dataclasses import dataclass -import pytest from nexusrpc.handler import service_handler from temporalio import nexus, workflow From e2e48be1bdaf4619ae861e41cf2815a7b026ba2c Mon Sep 17 00:00:00 2001 From: Quinn Klassen Date: Mon, 23 Feb 2026 15:38:41 -0800 Subject: [PATCH 4/5] Keep skipping headers test --- tests/nexus/test_workflow_caller.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/tests/nexus/test_workflow_caller.py b/tests/nexus/test_workflow_caller.py index 27fb208b0..f3d3055ee 100644 --- a/tests/nexus/test_workflow_caller.py +++ b/tests/nexus/test_workflow_caller.py @@ -2104,6 +2104,9 @@ async def test_task_executor_operation_cancel_method( self, client: Client, env: WorkflowEnvironment, use_async_cancel: bool ): """Test that both async and non-async cancel methods work for TaskExecutor-based operations.""" + if env.supports_time_skipping: + pytest.skip("Nexus tests don't work with time-skipping server") + task_queue = str(uuid.uuid4()) async with Worker( client, From 885180d7aedcb890aeb3d0a8c996bf423c38d674 Mon Sep 17 00:00:00 2001 From: Quinn Klassen Date: Mon, 23 Feb 2026 15:58:34 -0800 Subject: [PATCH 5/5] Skip test_cancel_operation_headers --- tests/nexus/test_workflow_caller.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tests/nexus/test_workflow_caller.py b/tests/nexus/test_workflow_caller.py index f3d3055ee..21a7425cd 100644 --- a/tests/nexus/test_workflow_caller.py +++ b/tests/nexus/test_workflow_caller.py @@ -859,6 +859,8 @@ async def test_cancel_operation_headers( env: WorkflowEnvironment, ): """Test headers from workflow and interceptor are propagated to cancel operation handler.""" + if env.supports_time_skipping: + pytest.skip("Nexus tests don't work with time-skipping server") task_queue = str(uuid.uuid4()) workflow_id = str(uuid.uuid4())