temporalio.bridge.worker.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_nexus_task Complete a nexus 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_nexus_task Poll for a nexus task.
Async Method poll_workflow_activation Poll for a workflow activation.
Method record_activity_heartbeat Record an activity heartbeat.
Method replace_client Replace the worker client.
Method request_workflow_eviction Request a workflow be evicted.
Async Method validate Validate the bridge worker.
Instance Variable _ref Undocumented

Create a bridge worker from a bridge client.

Create a bridge replay worker.

Create SDK core worker from a bridge worker.

Complete an activity task.

Complete a workflow activation.

Finalize the worker.

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

Start shutdown of the worker.

Poll for an activity task.

Poll for a workflow activation.

Record an activity heartbeat.

Replace the worker client.

Request a workflow be evicted.

Validate the bridge worker.