temporalio.worker._activity.

class documentation

class _ActivityWorker: (source)

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

Undocumented

Method	`__init__`	Undocumented
Async Method	`drain_poll_queue`	Undocumented
Method	`notify_shutdown`	Undocumented
Async Method	`run`	Undocumented
Async Method	`wait_all_completed`	Undocumented
Method	`_cancel`	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: Optional[concurrent.futures.Executor], shared_state_manager: Optional[SharedStateManager], data_converter: temporalio.converter.DataConverter, interceptors: Sequence[Interceptor], metric_meter: temporalio.common.MetricMeter): (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

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: Optional[temporalio.activity._Definition] = (source) ¶

Undocumented

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