Orchestrator Module¶

Orchestrator package.

class atloop.orchestrator.AgentLoop(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶

Bases: object

Agent loop - single responsibility: coordinate workflow execution.

__init__(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶: Initialize agent loop.

run() → Dict[str, Any][source]¶: Run agent - single method.

AgentLoop¶

class atloop.orchestrator.agent_loop.AgentLoop(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶

Bases: object

Agent loop - single responsibility: coordinate workflow execution.

__init__(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶: Initialize agent loop.

run() → Dict[str, Any][source]¶: Run agent - single method.

WorkflowCoordinator¶

class atloop.orchestrator.coordinator.WorkflowCoordinator(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶

Bases: object

Workflow coordinator - single entry point for all components.

__init__(task_spec: TaskSpec, config: AtloopConfig, agent_session_id: str | None = None)[source]¶: Initialize coordinator.

initialize() → bool[source]¶: Initialize workspace - single method.

property job_state: JobState¶: Get job state.

Workflow¶

class atloop.orchestrator.workflow.workflow.Workflow(coordinator: WorkflowCoordinator)[source]¶

Bases: object

Single workflow: DISCOVER -> PLAN -> ACT -> VERIFY.

__init__(coordinator: WorkflowCoordinator)[source]¶: Initialize workflow.

run() → Dict[str, Any][source]¶: Run workflow - single method.

Phases¶

class atloop.orchestrator.phases.discover.DiscoverPhase(coordinator: WorkflowCoordinator)[source]¶

Bases: BasePhase

DISCOVER phase: Build context and prepare for planning.

execute(context: PhaseContext) → PhaseResult[source]¶

Execute DISCOVER phase.

Parameters:: context – Phase execution context
Returns:: Phase execution result

class atloop.orchestrator.phases.plan.PlanPhase(coordinator: WorkflowCoordinator)[source]¶

Bases: BasePhase

PLAN phase: Call LLM to get next actions.

execute(context: PhaseContext) → PhaseResult[source]¶

Execute PLAN phase.

Parameters:: context – Phase execution context
Returns:: Phase execution result

class atloop.orchestrator.phases.act.ActPhase(coordinator: WorkflowCoordinator)[source]¶

Bases: BasePhase

ACT phase: Execute tool calls.

__init__(coordinator: WorkflowCoordinator)[source]¶: Initialize ACT phase.

execute(context: PhaseContext) → PhaseResult[source]¶

Execute ACT phase.

Parameters:: context – Phase execution context
Returns:: Phase execution result

class atloop.orchestrator.phases.verify.VerifyPhase(coordinator: WorkflowCoordinator)[source]¶

Bases: BasePhase

VERIFY phase: Run verification tests.

execute(context: PhaseContext) → PhaseResult[source]¶

Execute VERIFY phase.

Parameters:: context – Phase execution context
Returns:: Phase execution result