WorkerConf

class WorkerConf(BaseModel):

The configuration of a worker.

TaskResult

class TaskResult(BaseModel):

The result of a task.

TaskAssignResult

class TaskAssignResult(BaseModel):

The result of task assignment.

check_if_running

def check_if_running(running: bool):

Raises:

  • RuntimeError: If the workforce is not in the expected status.