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`	Continually poll for activity tasks and dispatch to handlers.
Async Method	`wait_all_completed`	Undocumented
Async Method	`_execute_activity`	Invoke the user's activity function.
Method	`_handle_cancel_activity_task`	Request cancellation of a running activity task.
Async Method	`_handle_start_activity_task`	Handle a start activity task.
Method	`_heartbeat`	Undocumented
Async Method	`_heartbeat_async`	Undocumented
Instance Variable	`_activities`	Undocumented
Instance Variable	`_activity_executor`	Undocumented
Instance Variable	`_bridge_worker`	Undocumented
Instance Variable	`_client`	Undocumented
Instance Variable	`_data_converter`	Undocumented
Instance Variable	`_dynamic_activity`	Undocumented
Instance Variable	`_encode_headers`	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, client: temporalio.client.Client, encode_headers: bool): (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) ¶

Continually poll for activity tasks and dispatch to handlers.

async def wait_all_completed(self): (source) ¶

Undocumented

async def _execute_activity(self, start: temporalio.bridge.proto.activity_task.Start, running_activity: _RunningActivity, task_token: bytes, data_converter: temporalio.converter.DataConverter) -> Any: (source) ¶

Invoke the user's activity function.

Exceptions are handled by a caller of this function.

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

Request cancellation of a running activity task.

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

Handle a start activity task.

Attempt to execute the user activity function and invoke the data converter on the result. Handle errors and send the task completion.

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

Undocumented