Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Task executor for running subagent tasks

Implementations

impl TaskExecutor

pub fn new( registry: Arc<AgentRegistry>, session_manager: Arc<SessionManager>, ) -> Self

Create a new task executor

pub async fn execute( &self, parent_session_id: &str, params: TaskParams, event_tx: Option<Sender<AgentEvent>>, ) -> Result<TaskResult>

Execute a task in a subagent

This creates a child session, runs the prompt, and returns the result.

pub fn execute_background( self: Arc<Self>, parent_session_id: String, params: TaskParams, event_tx: Option<Sender<AgentEvent>>, ) -> 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>, parent_session_id: &str, tasks: Vec<TaskParams>, event_tx: Option<Sender<AgentEvent>>, ) -> 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.