temporalio.worker._workflow.

class documentation

class _WorkflowWorker: (source)

Constructor: _WorkflowWorker(bridge_worker, namespace, task_queue, workflows, ...)

Undocumented

Method	`__init__`	Undocumented
Async Method	`drain_poll_queue`	Undocumented
Method	`notify_shutdown`	Undocumented
Async Method	`run`	Undocumented
Method	`_create_workflow_instance`	Undocumented
Async Method	`_handle_activation`	Undocumented
Instance Variable	`_bridge_worker`	Undocumented
Instance Variable	`_could_not_evict_count`	Undocumented
Instance Variable	`_data_converter`	Undocumented
Instance Variable	`_deadlock_timeout_seconds`	Undocumented
Instance Variable	`_disable_eager_activity_execution`	Undocumented
Instance Variable	`_disable_safe_eviction`	Undocumented
Instance Variable	`_dynamic_workflow`	Undocumented
Instance Variable	`_extern_functions`	Undocumented
Instance Variable	`_interceptor_classes`	Undocumented
Instance Variable	`_namespace`	Undocumented
Instance Variable	`_on_eviction_hook`	Undocumented
Instance Variable	`_running_workflows`	Undocumented
Instance Variable	`_task_queue`	Undocumented
Instance Variable	`_throw_after_activation`	Undocumented
Instance Variable	`_unsandboxed_workflow_runner`	Undocumented
Instance Variable	`_workflow_runner`	Undocumented
Instance Variable	`_workflow_task_executor`	Undocumented
Instance Variable	`_workflow_task_executor_user_provided`	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], 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

async def drain_poll_queue(self): (source) ¶

Undocumented

def notify_shutdown(self): (source) ¶

Undocumented

async def run(self): (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

_bridge_worker = (source) ¶

Undocumented

_could_not_evict_count: int = (source) ¶

Undocumented

_data_converter = (source) ¶

Undocumented

_deadlock_timeout_seconds = (source) ¶

Undocumented

_disable_eager_activity_execution = (source) ¶