Struct PlanExecutorAgent 

pub struct PlanExecutorAgent { /* private fields */ }

Plan Executor Agent - coordinates execution of a plan’s tasks

Implementations

impl PlanExecutorAgent

pub fn new( plan: PlanMetadata, task_manager: Arc<RwLock<TaskManager>>, config: PlanExecutionConfig, ) -> Self

Create a new plan executor

pub async fn plan(&self) -> PlanMetadata

Get the plan

pub async fn status(&self) -> PlanExecutionStatus

Get the execution status

pub async fn current_task_id(&self) -> Option<String>

Get the current task ID

pub fn approval_mode(&self) -> ExecutionApprovalMode

Get the approval mode

pub fn set_approval_mode(&mut self, mode: ExecutionApprovalMode)

Set the approval mode

pub fn needs_approval(&self, _task: &Task) -> bool

Check if a task needs approval based on current mode

pub async fn get_next_task(&self) -> Option<Task>

Get the next task to execute

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

Start executing a specific task

pub async fn complete_current_task( &self, summary: String, ) -> Result<Option<Task>>

Complete the current task

pub async fn skip_current_task( &self, reason: Option<String>, ) -> Result<Option<Task>>

Skip the current task

pub async fn fail_current_task(&self, error: String) -> Result<()>

Fail the current task

pub async fn pause(&self)

Pause execution

pub async fn resume(&self) -> Option<Task>

Resume execution

pub async fn request_approval(&self, task: &Task)

Request approval for a task (in Suggest mode)

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

Approve and start a task

pub async fn get_progress(&self) -> ExecutionProgress

Get execution progress

pub async fn format_progress(&self) -> String

Format progress as a string