class documentation
class _WorkflowWorker: (source)
Constructor: _WorkflowWorker(bridge_worker, namespace, task_queue, workflows, ...)
Undocumented
Method | __init__ |
Undocumented |
Async Method | drain |
Undocumented |
Method | nondeterminism |
Undocumented |
Method | nondeterminism |
Undocumented |
Method | notify |
Undocumented |
Async Method | run |
Undocumented |
Method | _create |
Undocumented |
Async Method | _handle |
Undocumented |
Instance Variable | _bridge |
Undocumented |
Instance Variable | _could |
Undocumented |
Instance Variable | _data |
Undocumented |
Instance Variable | _deadlock |
Undocumented |
Instance Variable | _disable |
Undocumented |
Instance Variable | _disable |
Undocumented |
Instance Variable | _dynamic |
Undocumented |
Instance Variable | _extern |
Undocumented |
Instance Variable | _interceptor |
Undocumented |
Instance Variable | _namespace |
Undocumented |
Instance Variable | _on |
Undocumented |
Instance Variable | _running |
Undocumented |
Instance Variable | _task |
Undocumented |
Instance Variable | _throw |
Undocumented |
Instance Variable | _unsandboxed |
Undocumented |
Instance Variable | _workflow |
Undocumented |
Instance Variable | _workflow |
Undocumented |
Instance Variable | _workflow |
Undocumented |
Instance Variable | _workflow |
Undocumented |
Instance Variable | _workflows |
Undocumented |
def __init__(self, *, bridge_worker:
Callable[ [], temporalio.bridge.worker.Worker]
, namespace: str
, task_queue: str
, workflows: Sequence[ Type]
, workflow_task_executor: Optional[ concurrent.futures.ThreadPoolExecutor]
, workflow_runner: WorkflowRunner
, unsandboxed_workflow_runner: WorkflowRunner
, data_converter: temporalio.converter.DataConverter
, interceptors: Sequence[ Interceptor]
, workflow_failure_exception_types: Sequence[ Type[ BaseException]]
, debug_mode: bool
, disable_eager_activity_execution: bool
, metric_meter: temporalio.common.MetricMeter
, on_eviction_hook: Optional[ Callable[ [ str, temporalio.bridge.proto.workflow_activation.RemoveFromCache], None]]
, disable_safe_eviction: bool
):
(source)
¶
Undocumented
def _create_workflow_instance(self, act:
temporalio.bridge.proto.workflow_activation.WorkflowActivation
, start: temporalio.bridge.proto.workflow_activation.StartWorkflow
) -> WorkflowInstance
:
(source)
¶
Undocumented
async def _handle_activation(self, act:
temporalio.bridge.proto.workflow_activation.WorkflowActivation
):
(source)
¶
Undocumented