Struct TaskOrchestrator 

pub struct TaskOrchestrator { /* private fields */ }

Bridges TaskManager and AgentPool with a dependency-aware scheduling loop.

Implementations

impl TaskOrchestrator

pub fn new( task_manager: Arc<TaskManager>, agent_pool: Arc<AgentPool>, communication_hub: Arc<CommunicationHub>, config: TaskOrchestratorConfig, ) -> Self

Create a new orchestrator.

pub async fn set_task_config( &self, task_id: impl Into<String>, config: TaskAgentConfig, )

Set a per-task agent config override.

pub async fn set_task_configs(&self, configs: HashMap<String, TaskAgentConfig>)

Bulk-set per-task agent config overrides.

pub async fn create_and_run( &self, parent_task_id: Option<&str>, specs: Vec<TaskSpec>, ) -> Result<OrchestrationResult>

Convenience API: create tasks with dependencies in the TaskManager, then run the scheduling loop.

parent_task_id is an optional root task under which all specs are created as subtasks.

pub async fn run(&self, root_task_id: &str) -> Result<OrchestrationResult>

Main scheduling loop over existing tasks in the TaskManager.

Runs until all tasks reachable from root_task_id are completed/failed or the failure policy halts scheduling.

pub async fn abort(&self)

Cancel all running agents and return.

pub async fn progress(&self) -> TaskStats

Live task statistics snapshot.

pub async fn running_agents(&self) -> HashMap<String, String>

Map of currently running agent_id -> task_id.