temporalio.worker.workflow_sandbox._runner._Instance

class documentation

class _Instance(WorkflowInstance): (source)

Constructor: _Instance(instance_details, runner_class, restrictions)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method activate Handle an activation and return completion.
Method get_thread_id Return the thread identifier that this workflow is running on.
Instance Variable globals_and_locals Undocumented
Instance Variable importer Undocumented
Instance Variable instance_details Undocumented
Instance Variable runner_class Undocumented
Method _create_instance Undocumented
Method _run_code Undocumented
Instance Variable _current_thread_id Undocumented
def __init__(self, instance_details: WorkflowInstanceDetails, runner_class: Type[WorkflowRunner], restrictions: SandboxRestrictions): (source)

Undocumented

def activate(self, act: temporalio.bridge.proto.workflow_activation.WorkflowActivation) -> temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion: (source)
overrides temporalio.worker.WorkflowInstance.activate

Handle an activation and return completion.

This should never raise an exception, but instead catch all exceptions and set as completion failure.

Parameters
act:temporalio.bridge.proto.workflow_activation.WorkflowActivationProtobuf activation.
Returns
temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletionCompletion object with successful commands set or failure info set.
def get_thread_id(self) -> Optional[int]: (source)
overrides temporalio.worker.WorkflowInstance.get_thread_id

Return the thread identifier that this workflow is running on.

Not an abstractmethod because it is not mandatory to implement. Used primarily for getting the frames of a deadlocked thread.

Returns
Optional[int]Thread ID if the workflow is running, None if not.
globals_and_locals: dict[str, str] = (source)

Undocumented

importer = (source)

Undocumented

instance_details = (source)

Undocumented

runner_class = (source)

Undocumented

def _create_instance(self): (source)

Undocumented

def _run_code(self, code: str, **extra_globals: Any): (source)

Undocumented

_current_thread_id = (source)

Undocumented