class documentation
class _Instance(WorkflowInstance): (source)
Constructor: _Instance(instance_details, runner_class, restrictions)
Undocumented
| Method | __init__ |
Undocumented |
| Method | activate |
Handle an activation and return completion. |
| Method | get |
Return appropriate serialization context. |
| Method | get |
Return the thread identifier that this workflow is running on. |
| Instance Variable | globals |
Undocumented |
| Instance Variable | importer |
Undocumented |
| Instance Variable | instance |
Undocumented |
| Instance Variable | runner |
Undocumented |
| Method | _create |
Undocumented |
| Method | _run |
Undocumented |
| Instance Variable | _current |
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)
¶
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.WorkflowActivation | Protobuf activation. |
| Returns | |
temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion | Completion object with successful commands set or failure info set. |
def get_serialization_context(self, command_info:
_command_aware_visitor.CommandInfo | None) -> temporalio.converter.SerializationContext | None:
(source)
¶
Return appropriate serialization context.
| Parameters | |
command_command_aware_visitor.CommandInfo | None | Optional information identifying the associated command. If set, the payload codec will have serialization context set appropriately for that command. |
| Returns | |
temporalio.converter.SerializationContext | None | The serialization context, or None if no context should be set. |