Workers poll a named task queue, execute idempotent business logic, and return a
result. Define a function worker with @worker_task, then run it with
TaskHandler or AsyncTaskRunner.
from conductor.client.worker.worker_task import worker_task
@worker_task(task_definition_name="greet")
def greet(name: str) -> dict:
return {"result": f"Hello {name}"}Use explicit retries, task timeouts, and domains for production isolation. Stop task handlers during application shutdown. See the detailed worker guide, reliability, and workflow testing.