Skip to content

Commit 59b47cb

Browse files
committed
Revert disabling of sandbox for nexus workflow tests
1 parent 47ceb4a commit 59b47cb

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

tests/nexus/test_workflow_caller.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
from temporalio.exceptions import CancelledError, NexusHandlerError, NexusOperationError
4141
from temporalio.nexus import WorkflowRunOperationContext, workflow_run_operation
4242
from temporalio.service import RPCError, RPCStatusCode
43-
from temporalio.worker import UnsandboxedWorkflowRunner, Worker
43+
from temporalio.worker import Worker
4444
from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
4545

4646
# TODO(dan): test availability of Temporal client etc in async context set by worker
@@ -444,8 +444,6 @@ async def test_sync_response(
444444
nexus_service_handlers=[ServiceImpl()],
445445
workflows=[CallerWorkflow, HandlerWorkflow],
446446
task_queue=task_queue,
447-
# TODO(dan): enable sandbox
448-
workflow_runner=UnsandboxedWorkflowRunner(),
449447
workflow_failure_exception_types=[Exception],
450448
):
451449
await create_nexus_endpoint(task_queue, client)
@@ -517,7 +515,6 @@ async def test_async_response(
517515
nexus_service_handlers=[ServiceImpl()],
518516
workflows=[CallerWorkflow, HandlerWorkflow],
519517
task_queue=task_queue,
520-
workflow_runner=UnsandboxedWorkflowRunner(),
521518
workflow_failure_exception_types=[Exception],
522519
):
523520
caller_wf_handle, handler_wf_handle = await _start_wf_and_nexus_op(
@@ -673,7 +670,6 @@ async def test_untyped_caller(
673670
workflows=[UntypedCallerWorkflow, HandlerWorkflow],
674671
nexus_service_handlers=[ServiceImpl()],
675672
task_queue=task_queue,
676-
workflow_runner=UnsandboxedWorkflowRunner(),
677673
workflow_failure_exception_types=[Exception],
678674
):
679675
if response_type == SyncResponse:
@@ -851,7 +847,6 @@ async def test_service_interface_and_implementation_names(client: Client):
851847
],
852848
workflows=[ServiceInterfaceAndImplCallerWorkflow],
853849
task_queue=task_queue,
854-
workflow_runner=UnsandboxedWorkflowRunner(),
855850
workflow_failure_exception_types=[Exception],
856851
):
857852
await create_nexus_endpoint(task_queue, client)
@@ -965,7 +960,6 @@ async def test_workflow_run_operation_can_execute_workflow_before_starting_backi
965960
ServiceImplWithOperationsThatExecuteWorkflowBeforeStartingBackingWorkflow(),
966961
],
967962
task_queue=task_queue,
968-
workflow_runner=UnsandboxedWorkflowRunner(),
969963
):
970964
await create_nexus_endpoint(task_queue, client)
971965
result = await client.execute_workflow(

0 commit comments

Comments
 (0)