Skip tests under Java test server

Author: dandavison

tests/nexus/test_workflow_caller.py

@@ -47,6 +47,7 @@
 )
 from temporalio.nexus import WorkflowRunOperationContext, workflow_run_operation
 from temporalio.service import RPCError, RPCStatusCode
+from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
 from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
 
@@ -443,11 +444,15 @@ async def run(
 )
 async def test_sync_response(
     client: Client,
+    env: WorkflowEnvironment,
     exception_in_operation_start: bool,
     request_cancel: bool,
     op_definition_type: OpDefinitionType,
     caller_reference: CallerReference,
 ):
+    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,
@@ -514,11 +519,15 @@ async def test_sync_response(
 )
 async def test_async_response(
     client: Client,
+    env: WorkflowEnvironment,
     exception_in_operation_start: bool,
     request_cancel: bool,
     op_definition_type: OpDefinitionType,
     caller_reference: CallerReference,
 ):
+    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,
@@ -669,11 +678,15 @@ async def _start_wf_and_nexus_op(
 @pytest.mark.parametrize("response_type", [SyncResponse, AsyncResponse])
 async def test_untyped_caller(
     client: Client,
+    env: WorkflowEnvironment,
     exception_in_operation_start: bool,
     op_definition_type: OpDefinitionType,
     caller_reference: CallerReference,
     response_type: ResponseType,
 ):
+    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,
@@ -830,7 +843,12 @@ async def run(
 # TODO(nexus-prerelease): check missing decorator behavior
 
 
-async def test_service_interface_and_implementation_names(client: Client):
+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.
@@ -956,7 +974,11 @@ async def run(self, input: str, task_queue: str) -> str:
 
 async def test_workflow_run_operation_can_execute_workflow_before_starting_backing_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())
     async with Worker(
         client,
@@ -1222,7 +1244,12 @@ async def run(self, op: str, input: OverloadTestValue) -> OverloadTestValue:
         "by_name_multi_param",
     ],
 )
-async def test_workflow_run_operation_overloads(client: Client, op: str):
+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,

tests/nexus/test_workflow_caller_error_chains.py

@@ -20,6 +20,7 @@
     ApplicationError,
     NexusOperationError,
 )
+from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
 from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
 
@@ -398,8 +399,11 @@ async def invoke_nexus_op_and_assert_error(self, input: ErrorTestInput) -> None:
 
 @pytest.mark.parametrize("test_case", list(error_conversion_test_cases.values()))
 async def test_errors_raised_by_nexus_operation(
-    client: Client, test_case: type[ErrorConversionTestCase]
+    client: Client, env: WorkflowEnvironment, test_case: type[ErrorConversionTestCase]
 ):
+    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,

tests/nexus/test_workflow_caller_errors.py

@@ -31,6 +31,7 @@
     NexusOperationError,
     TimeoutError,
 )
+from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
 from tests.helpers import assert_eq_eventually
 from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
@@ -107,7 +108,12 @@ async def run(self, input: ErrorTestInput) -> None:
         "retried_due_to_internal_handler_error",
     ],
 )
-async def test_nexus_operation_is_retried(client: Client, operation_name: str):
+async def test_nexus_operation_is_retried(
+    client: Client, env: WorkflowEnvironment, operation_name: str
+):
+    if env.supports_time_skipping:
+        pytest.skip("Nexus tests don't work with time-skipping server")
+
     input = ErrorTestInput(
         service_name="ErrorTestService",
         operation_name=operation_name,
@@ -154,10 +160,14 @@ async def times_called() -> int:
 )
 async def test_nexus_operation_fails_without_retry_as_handler_error(
     client: Client,
+    env: WorkflowEnvironment,
     operation_name: str,
     handler_error_type: nexusrpc.HandlerErrorType,
     handler_error_message: str,
 ):
+    if env.supports_time_skipping:
+        pytest.skip("Nexus tests don't work with time-skipping server")
+
     input = ErrorTestInput(
         service_name=(
             "ErrorTestService"
@@ -224,7 +234,12 @@ async def run(self) -> None:
         )
 
 
-async def test_error_raised_by_timeout_of_nexus_start_operation(client: Client):
+async def test_error_raised_by_timeout_of_nexus_start_operation(
+    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,
@@ -302,7 +317,12 @@ async def run(self) -> None:
         await op_handle
 
 
-async def test_error_raised_by_timeout_of_nexus_cancel_operation(client: Client):
+async def test_error_raised_by_timeout_of_nexus_cancel_operation(
+    client: Client, env: WorkflowEnvironment
+):
+    if env.supports_time_skipping:
+        pytest.skip("Nexus tests don't work with time-skipping server")
+
     pytest.skip("TODO(nexus-prerelease): finish writing this test")
     task_queue = str(uuid.uuid4())
     async with Worker(