Skip to main content

WorkforceCallback

class WorkforceCallback(ABC):
Interface for recording workforce lifecycle events. Implementations should persist or stream events as appropriate.

log_task_created

def log_task_created(self, event: TaskCreatedEvent):

log_task_decomposed

def log_task_decomposed(self, event: TaskDecomposedEvent):

log_task_assigned

def log_task_assigned(self, event: TaskAssignedEvent):

log_task_started

def log_task_started(self, event: TaskStartedEvent):

log_task_completed

def log_task_completed(self, event: TaskCompletedEvent):

log_task_failed

def log_task_failed(self, event: TaskFailedEvent):

log_worker_created

def log_worker_created(self, event: WorkerCreatedEvent):

log_worker_deleted

def log_worker_deleted(self, event: WorkerDeletedEvent):

log_all_tasks_completed

def log_all_tasks_completed(self, event: AllTasksCompletedEvent):
I