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	`nondeterminism_as_workflow_fail`	Undocumented
Method	`nondeterminism_as_workflow_fail_for_types`	Undocumented
Method	`notify_shutdown`	Undocumented
Async Method	`run`	Undocumented
Method	`_create_workflow_instance`	Undocumented
Async Method	`_handle_activation`	Undocumented
Async Method	`_handle_cache_eviction`	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	`_encode_headers`	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_failure_exception_types`	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: concurrent.futures.ThreadPoolExecutor | None, max_concurrent_workflow_tasks: int | None, 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: Callable[[str, temporalio.bridge.proto.workflow_activation.RemoveFromCache], None] | None, disable_safe_eviction: bool, should_enforce_versioning_behavior: bool, assert_local_activity_valid: Callable[[str], None], encode_headers: bool): (source) ¶

Undocumented

async def drain_poll_queue(self): (source) ¶

Undocumented

def nondeterminism_as_workflow_fail(self) -> bool: (source) ¶

Undocumented

def nondeterminism_as_workflow_fail_for_types(self) -> set[str]: (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, init: temporalio.bridge.proto.workflow_activation.InitializeWorkflow) -> WorkflowInstance: (source) ¶

Undocumented

async def _handle_activation(self, act: temporalio.bridge.proto.workflow_activation.WorkflowActivation): (source) ¶

Undocumented

async def _handle_cache_eviction(self, act: temporalio.bridge.proto.workflow_activation.WorkflowActivation, job: temporalio.bridge.proto.workflow_activation.RemoveFromCache): (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) ¶

Undocumented

_disable_safe_eviction = (source) ¶