Struct TaskOrchestrator 

pub struct TaskOrchestrator { /* private fields */ }

The task orchestrator — manages the full lifecycle of task plans.

Fields are pub(crate) so per-action handlers (crate::actions) and aggregation helpers (crate::aggregation) can split impl across sibling modules. Outside the orchestrate crate the struct’s surface is the public methods only.

Implementations

impl TaskOrchestrator

pub async fn execute(&self, task_id: &str) -> Result<String, OrchestrateError>

Execute a previously planned task (after user approval).

impl TaskOrchestrator

pub async fn plan( &self, request: &str, context: DecompositionContext, ) -> Result<(String, String), OrchestrateError>

Decompose a user request into a task plan. Returns the task ID and a formatted plan for user review.

pub async fn get_task(&self, task_id: &str) -> Option<TaskState>

Get the current state of a task.

pub async fn pending_approvals(&self) -> Vec<String>

Return task IDs currently in the AwaitingApproval phase. Used by the signal pipeline to resolve bare approve / reject (no id) to the single pending plan when there’s exactly one.

pub async fn list_tasks(&self) -> Vec<(String, String, TaskPhase)>

List all active tasks.

pub async fn cancel(&self, task_id: &str) -> Result<(), OrchestrateError>

Cancel a task. Flips all non-terminal step states to Cancelled, transitions the task phase to Cancelled, and (PR-6b) fires the per-task CancellationToken so any in-flight step future observing the token aborts within one polling cycle — without PR-6b, cancellation would have to wait for the current step to finish on its own.

impl TaskOrchestrator

pub fn new(decomposer: Arc<dyn TaskDecomposer>) -> Self

pub fn with_available_tools(self, tools: Vec<String>) -> Self

Cache the sandbox’s binary allowlist so the replan-on-failure loop can include it in its corrective LLM call. Without this the replan call has no allowlist context and may suggest binaries the sandbox would reject.

pub fn with_audit(self, audit: Arc<dyn AuditTrail>) -> Self

pub fn with_confirmation(self, confirm: Arc<dyn ConfirmationEngine>) -> Self

pub fn with_budget(self, budget: Arc<dyn CostBudget>) -> Self

pub fn with_sandbox(self, sandbox: Arc<dyn SandboxExecutor>) -> Self

pub fn with_agents(self, agents: Arc<AgentRegistry>) -> Self

Attach the agent registry — enables StepAction::Implement dispatch to specialist delegates.

pub fn with_llm(self, llm: Arc<dyn LlmProvider>) -> Self

Attach an LLM provider so Research and Review steps actually run a model call instead of returning a no-op string.

pub fn with_channel_dispatcher(self, dispatcher: Arc<ChannelDispatcher>) -> Self

Attach a channel dispatcher so Notify steps actually deliver the message to the user’s preferred channel.

pub fn with_episodic(self, store: Arc<EpisodicStore>) -> Self

Attach an episodic memory store — delegate outcomes are recorded so they’re searchable in future sessions.

pub fn with_observer(self, observer: Arc<dyn Observer>) -> Self

Attach an observer bus so phase transitions emit observe::BrainEvent::TaskStateChange. Unwired = silent.

pub fn with_state_pool(self, pool: SqlitePool) -> Self

Attach a SQLite pool so phase transitions append rows to the task_states audit table (migration v22). Unwired = in-memory history only.

pub fn with_delegation_policy(self, policy: EscalationPolicy) -> Self

Override the default delegation escalation policy.