Fix test. Use sano dev server and add required dynamic config

VegetarianOrc · VegetarianOrc · commit e390b8335684 · 2026-06-04T14:11:22.000-07:00
diff --git a/tests/conftest.py b/tests/conftest.py
@@ -42,12 +42,17 @@ async def env(request) -> AsyncGenerator[WorkflowEnvironment, None]:
     env_type = request.config.getoption("--workflow-environment")
     if env_type == "local":
         env = await WorkflowEnvironment.start_local(
+            dev_server_download_version="v1.7.1-standalone-nexus-operations",
             dev_server_extra_args=[
                 "--dynamic-config-value",
                 "frontend.enableExecuteMultiOperation=true",
                 "--dynamic-config-value",
                 "system.enableEagerWorkflowStart=true",
-            ]
+                "--dynamic-config-value",
+                "nexusoperation.enableStandalone=true",
+                "--dynamic-config-value",
+                "history.enableChasmCallbacks=true",
+            ],
         )
     elif env_type == "time-skipping":
         env = await WorkflowEnvironment.start_time_skipping()
diff --git a/tests/nexus_standalone_operations/nexus_standalone_operations_test.py b/tests/nexus_standalone_operations/nexus_standalone_operations_test.py
@@ -1,11 +1,7 @@
-import asyncio
-import os
 import uuid
 from datetime import timedelta
 
-import pytest
-from temporalio.client import Client, NexusOperationFailureError
-from temporalio.service import RPCError
+from temporalio.client import Client
 from temporalio.worker import Worker
 
 from nexus_standalone_operations.handler import HelloWorkflow, MyNexusServiceHandler
@@ -21,11 +17,6 @@
 
 
 async def test_nexus_standalone_operations(client: Client):
-    if not os.getenv("ENABLE_STANDALONE_NEXUS_TESTS"):
-        pytest.skip(
-            "Standalone Nexus operations not yet supported by default dev server. Set ENABLE_STANDALONE_NEXUS_TESTS=1 to enable."
-        )
-
     endpoint_name = f"test-nexus-standalone-{uuid.uuid4()}"
 
     create_response = await create_nexus_endpoint(
@@ -44,19 +35,14 @@ async def test_nexus_standalone_operations(client: Client):
                 service=MyNexusService, endpoint=endpoint_name
             )
 
-            # Test sync echo operation (with retry for endpoint propagation)
+            # Test sync echo operation
             echo_result = None
-            for _ in range(30):
-                try:
-                    echo_result = await nexus_client.execute_operation(
-                        MyNexusService.echo,
-                        EchoInput(message="test-echo"),
-                        id=str(uuid.uuid4()),
-                        schedule_to_close_timeout=timedelta(seconds=10),
-                    )
-                    break
-                except (RPCError, NexusOperationFailureError):
-                    await asyncio.sleep(0.5)
+            echo_result = await nexus_client.execute_operation(
+                MyNexusService.echo,
+                EchoInput(message="test-echo"),
+                id=str(uuid.uuid4()),
+                schedule_to_close_timeout=timedelta(seconds=10),
+            )
             assert isinstance(echo_result, EchoOutput)
             assert echo_result.message == "test-echo"
 
