Stop skipping some Nexus tests on time skipping test server (#1338)

Stop skipping some Nexus tests

Author: Quinn-With-Two-Ns

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
@@ -91,9 +90,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())
 

tests/nexus/test_workflow_caller.py

@@ -663,8 +663,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,
@@ -701,8 +699,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,
@@ -903,9 +899,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"}
 
@@ -1387,9 +1380,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.
@@ -1518,9 +1508,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,
@@ -1574,9 +1561,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,
@@ -1869,9 +1853,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,
@@ -1940,9 +1921,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)
@@ -2019,9 +1997,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(

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(