|
41 | 41 | from temporalio.nexus import workflow_run_operation
|
42 | 42 | from temporalio.nexus._workflow import WorkflowRunOperationContext
|
43 | 43 | from temporalio.service import RPCError, RPCStatusCode
|
44 |
| -from temporalio.worker import UnsandboxedWorkflowRunner, Worker |
| 44 | +from temporalio.worker import Worker |
45 | 45 | from tests.helpers.nexus import create_nexus_endpoint, make_nexus_endpoint_name
|
46 | 46 |
|
47 | 47 | # TODO(dan): test availability of Temporal client etc in async context set by worker
|
@@ -445,8 +445,6 @@ async def test_sync_response(
|
445 | 445 | nexus_service_handlers=[ServiceImpl()],
|
446 | 446 | workflows=[CallerWorkflow, HandlerWorkflow],
|
447 | 447 | task_queue=task_queue,
|
448 |
| - # TODO(dan): enable sandbox |
449 |
| - workflow_runner=UnsandboxedWorkflowRunner(), |
450 | 448 | workflow_failure_exception_types=[Exception],
|
451 | 449 | ):
|
452 | 450 | await create_nexus_endpoint(task_queue, client)
|
@@ -518,7 +516,6 @@ async def test_async_response(
|
518 | 516 | nexus_service_handlers=[ServiceImpl()],
|
519 | 517 | workflows=[CallerWorkflow, HandlerWorkflow],
|
520 | 518 | task_queue=task_queue,
|
521 |
| - workflow_runner=UnsandboxedWorkflowRunner(), |
522 | 519 | workflow_failure_exception_types=[Exception],
|
523 | 520 | ):
|
524 | 521 | caller_wf_handle, handler_wf_handle = await _start_wf_and_nexus_op(
|
@@ -674,7 +671,6 @@ async def test_untyped_caller(
|
674 | 671 | workflows=[UntypedCallerWorkflow, HandlerWorkflow],
|
675 | 672 | nexus_service_handlers=[ServiceImpl()],
|
676 | 673 | task_queue=task_queue,
|
677 |
| - workflow_runner=UnsandboxedWorkflowRunner(), |
678 | 674 | workflow_failure_exception_types=[Exception],
|
679 | 675 | ):
|
680 | 676 | if response_type == SyncResponse:
|
@@ -852,7 +848,6 @@ async def test_service_interface_and_implementation_names(client: Client):
|
852 | 848 | ],
|
853 | 849 | workflows=[ServiceInterfaceAndImplCallerWorkflow],
|
854 | 850 | task_queue=task_queue,
|
855 |
| - workflow_runner=UnsandboxedWorkflowRunner(), |
856 | 851 | workflow_failure_exception_types=[Exception],
|
857 | 852 | ):
|
858 | 853 | await create_nexus_endpoint(task_queue, client)
|
@@ -966,7 +961,6 @@ async def test_workflow_run_operation_can_execute_workflow_before_starting_backi
|
966 | 961 | ServiceImplWithOperationsThatExecuteWorkflowBeforeStartingBackingWorkflow(),
|
967 | 962 | ],
|
968 | 963 | task_queue=task_queue,
|
969 |
| - workflow_runner=UnsandboxedWorkflowRunner(), |
970 | 964 | ):
|
971 | 965 | await create_nexus_endpoint(task_queue, client)
|
972 | 966 | result = await client.execute_workflow(
|
|
0 commit comments