temporalio.bridge.worker.Worker

class documentation

class Worker: (source)

SDK Core worker.

Static Method	`create`	Create a bridge worker from a bridge client.
Static Method	`for_replay`	Create a bridge replay worker.
Method	`__init__`	Create SDK core worker from a bridge worker.
Async Method	`complete_activity_task`	Complete an activity task.
Async Method	`complete_workflow_activation`	Complete a workflow activation.
Async Method	`finalize_shutdown`	Finalize the worker.
Method	`initiate_shutdown`	Start shutdown of the worker.
Async Method	`poll_activity_task`	Poll for an activity task.
Async Method	`poll_workflow_activation`	Poll for a workflow activation.
Method	`record_activity_heartbeat`	Record an activity heartbeat.
Method	`request_workflow_eviction`	Request a workflow be evicted.
Instance Variable	`_ref`	Undocumented

@staticmethod
def create(client: temporalio.bridge.client.Client, config: WorkerConfig) -> Worker: (source) ¶

Create a bridge worker from a bridge client.

@staticmethod
def for_replay(runtime: temporalio.bridge.runtime.Runtime, config: WorkerConfig) -> Tuple[Worker, temporalio.bridge.temporal_sdk_bridge.HistoryPusher]: (source) ¶

Create a bridge replay worker.

def __init__(self, ref: temporalio.bridge.temporal_sdk_bridge.WorkerRef): (source) ¶

Create SDK core worker from a bridge worker.

async def complete_activity_task(self, comp: temporalio.bridge.proto.ActivityTaskCompletion): (source) ¶

Complete an activity task.

async def complete_workflow_activation(self, comp: temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion): (source) ¶

Complete a workflow activation.

async def finalize_shutdown(self): (source) ¶

Finalize the worker.

This will fail if shutdown hasn't completed fully due to internal reference count checks.

def initiate_shutdown(self): (source) ¶

Start shutdown of the worker.

async def poll_activity_task(self) -> temporalio.bridge.proto.activity_task.ActivityTask: (source) ¶

Poll for an activity task.

async def poll_workflow_activation(self) -> temporalio.bridge.proto.workflow_activation.WorkflowActivation: (source) ¶

Poll for a workflow activation.

def record_activity_heartbeat(self, comp: temporalio.bridge.proto.ActivityHeartbeat): (source) ¶

Record an activity heartbeat.

def request_workflow_eviction(self, run_id: str): (source) ¶

Request a workflow be evicted.

Undocumented