temporalio.worker._activity.

class documentation

class _ActivityWorker: (source)

Constructor: _ActivityWorker(bridge_worker, task_queue, activities, activity_executor, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`assert_activity_valid`	Undocumented
Async Method	`drain_poll_queue`	Undocumented
Method	`notify_shutdown`	Undocumented
Async Method	`run`	Undocumented
Async Method	`wait_all_completed`	Undocumented
Method	`_cancel`	Undocumented
Async Method	`_execute_activity`	Undocumented
Method	`_heartbeat`	Undocumented
Async Method	`_heartbeat_async`	Undocumented
Async Method	`_run_activity`	Undocumented
Instance Variable	`_activities`	Undocumented
Instance Variable	`_activity_executor`	Undocumented
Instance Variable	`_bridge_worker`	Undocumented
Instance Variable	`_data_converter`	Undocumented
Instance Variable	`_dynamic_activity`	Undocumented
Instance Variable	`_fail_worker_exception_queue`	Undocumented
Instance Variable	`_interceptors`	Undocumented
Instance Variable	`_metric_meter`	Undocumented
Instance Variable	`_running_activities`	Undocumented
Instance Variable	`_seen_sync_activity`	Undocumented
Instance Variable	`_shared_state_manager`	Undocumented
Instance Variable	`_task_queue`	Undocumented
Instance Variable	`_worker_shutdown_event`	Undocumented

def __init__(self, *, bridge_worker: Callable[[], temporalio.bridge.worker.Worker], task_queue: str, activities: Sequence[Callable], activity_executor: concurrent.futures.Executor | None, shared_state_manager: SharedStateManager | None, data_converter: temporalio.converter.DataConverter, interceptors: Sequence[Interceptor], metric_meter: temporalio.common.MetricMeter): (source) ¶

Undocumented

def assert_activity_valid(self, activity): (source) ¶

Undocumented

async def drain_poll_queue(self): (source) ¶

Undocumented

def notify_shutdown(self): (source) ¶

Undocumented

async def run(self): (source) ¶

Undocumented

async def wait_all_completed(self): (source) ¶

Undocumented

def _cancel(self, task_token: bytes, cancel: temporalio.bridge.proto.activity_task.Cancel): (source) ¶

Undocumented

async def _execute_activity(self, start: temporalio.bridge.proto.activity_task.Start, running_activity: _RunningActivity, completion: temporalio.bridge.proto.ActivityTaskCompletion): (source) ¶

Undocumented

def _heartbeat(self, task_token: bytes, *details: Any): (source) ¶

Undocumented

async def _heartbeat_async(self, logger: logging.LoggerAdapter, activity: _RunningActivity, task_token: bytes): (source) ¶

Undocumented

async def _run_activity(self, task_token: bytes, start: temporalio.bridge.proto.activity_task.Start, running_activity: _RunningActivity): (source) ¶

Undocumented

_activities: dict[str, temporalio.activity._Definition] = (source) ¶

Undocumented

_activity_executor = (source) ¶

Undocumented

_bridge_worker = (source) ¶

Undocumented

_data_converter = (source) ¶

Undocumented

_dynamic_activity: temporalio.activity._Definition | None = (source) ¶

Undocumented

_fail_worker_exception_queue: asyncio.Queue[Exception] = (source) ¶