Skip to main content

Worker

A worker node that works on tasks. It is the basic unit of task processing in the workforce system. Parameters:
  • description (str): Description of the node.
  • node_id (Optional[str]): ID of the node. If not provided, it will be generated automatically. (default: :obj:None)

init

repr

_get_dep_tasks_info

set_channel

stop

Forcefully stop the worker. Cancels all running tasks immediately and sets the stop flag. The worker will exit after completing cancellation.