temporalio.worker.workflow_sandbox.SandboxedWorkflowRunner

class documentation

class SandboxedWorkflowRunner(WorkflowRunner): (source)

Constructor: SandboxedWorkflowRunner(restrictions, runner_class)

View In Hierarchy

Runner for workflows in a sandbox.

Method __init__ Create the sandboxed workflow runner.
Method create_instance Implements WorkflowRunner.create_instance.
Method prepare_workflow Implements WorkflowRunner.prepare_workflow.
Method set_worker_level_failure_exception_types Implements WorkflowRunner.set_worker_level_failure_exception_types.
Instance Variable _restrictions Undocumented
Instance Variable _runner_class Undocumented
Instance Variable _worker_level_failure_exception_types Undocumented
def __init__(self, *, restrictions: SandboxRestrictions = SandboxRestrictions.default, runner_class: Type[WorkflowRunner] = UnsandboxedWorkflowRunner): (source)

Create the sandboxed workflow runner.

Parameters
restrictions:SandboxRestrictionsSet of restrictions to apply to this sandbox.
runner_class:Type[WorkflowRunner]The class for underlying runner the sandbox will instantiate and use to run workflows. Note, this class is re-imported and instantiated for each workflow run.
def create_instance(self, det: WorkflowInstanceDetails) -> WorkflowInstance: (source)
overrides temporalio.worker.WorkflowRunner.create_instance
def prepare_workflow(self, defn: temporalio.workflow._Definition): (source)
overrides temporalio.worker.WorkflowRunner.prepare_workflow
def set_worker_level_failure_exception_types(self, types: Sequence[type[BaseException]]): (source)
overrides temporalio.worker.WorkflowRunner.set_worker_level_failure_exception_types
_restrictions = (source)

Undocumented

_runner_class = (source)

Undocumented

_worker_level_failure_exception_types = (source)

Undocumented