Skip to content

antikythera.models.tasks ¤

Classes¤

DependencyType ¤

Enumeration of possible dependency types.

Used by:

ExecutionMode ¤

Enumeration of execution modes.

Used by:

SystemTaskType ¤

Enumeration of system task types.

TaskAllocationMessage ¤

TaskAllocationMessage(
    task_id: str, assigned_agent_id: str, timestamp: datetime | None = None
)

Task allocation message sent by orchestrator to agents.

TaskAssignmentMessage ¤

TaskAssignmentMessage(
    id: str,
    type: str,
    inputs: dict[str, Any] = None,
    output_keys: list[str] = None,
    params: dict[str, Any] = None,
    context: dict[str, Any] = None,
    timestamp: datetime = None,
    execution_mode: ExecutionMode = EXCLUSIVE,
)

Task assignment message sent by orchestrator to agents.

TaskClaimRequest ¤

TaskClaimRequest(task_id: str, agent_id: str, timestamp: datetime | None = None)

Task claim request sent by agents to orchestrator.

Used by:

TaskCompletionAckMessage ¤

TaskCompletionAckMessage(
    id: str, state: TaskState, accepted_agent_id: str, timestamp: datetime | None = None
)

Task completion acknowledgement message sent by orchestrator.

TaskCompletionMessage ¤

TaskCompletionMessage(
    id: str,
    state: TaskState,
    outputs: dict[str, Any] = None,
    error: TaskError | None = None,
    timestamp: datetime | None = None,
    duration_ms: int | None = None,
    agent_id: str | None = None,
)

Task completion message sent by agents to orchestrator.

Used by:

TaskError ¤

TaskError(code: str, message: str, details: Any | None = None)

Task error information.

Used by:

TaskState ¤

Enumeration of possible task states.

Used by: