temporalio.bridge.worker.Worker
| Static Method | create |
Create a bridge worker from a bridge client. |
| Static Method | for |
Create a bridge replay worker. |
| Method | __init__ |
Create SDK core worker from a bridge worker. |
| Async Method | complete |
Complete an activity task. |
| Async Method | complete |
Complete a nexus task. |
| Async Method | complete |
Complete a workflow activation. |
| Async Method | finalize |
Finalize the worker. |
| Method | initiate |
Start shutdown of the worker. |
| Async Method | poll |
Poll for an activity task. |
| Async Method | poll |
Poll for a nexus task. |
| Async Method | poll |
Poll for a workflow activation. |
| Method | record |
Record an activity heartbeat. |
| Method | replace |
Replace the worker client. |
| Method | request |
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.