Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Task executor for running subagent tasks

Implementations

impl TaskExecutor

pub fn new( registry: Arc<AgentRegistry>, llm_client: Arc<dyn LlmClient>, workspace: String, ) -> Self

Create a new task executor

pub fn with_mcp( registry: Arc<AgentRegistry>, llm_client: Arc<dyn LlmClient>, workspace: String, mcp_manager: Arc<McpManager>, ) -> Self

Create a new task executor with MCP manager for tool inheritance

pub async fn execute( &self, params: TaskParams, event_tx: Option<Sender<AgentEvent>>, sentinel_hook: Option<Arc<dyn HookExecutor>>, ) -> Result<TaskResult>

Execute a task by spawning an isolated child AgentLoop.

pub fn execute_background( self: Arc<Self>, params: TaskParams, event_tx: Option<Sender<AgentEvent>>, sentinel_hook: Option<Arc<dyn HookExecutor>>, ) -> String

Execute a task in the background.

Returns immediately with the task ID. Use events to track progress.

pub async fn execute_parallel( self: &Arc<Self>, tasks: Vec<TaskParams>, event_tx: Option<Sender<AgentEvent>>, sentinel_hook: Option<Arc<dyn HookExecutor>>, ) -> Vec<TaskResult>

Execute multiple tasks in parallel.

Spawns all tasks concurrently and waits for all to complete. Returns results in the same order as the input tasks.