Struct ExecutionPlan 

pub struct ExecutionPlan {
    pub goal: String,
    pub steps: Vec<Task>,
    pub complexity: Complexity,
    pub required_tools: Vec<String>,
    pub estimated_steps: usize,
}

Execution plan for a task

Fields

goal: String

High-level goal

steps: Vec<Task>

Decomposed steps

complexity: Complexity

Estimated complexity

required_tools: Vec<String>

Required tools

estimated_steps: usize

Estimated total steps

Implementations

impl ExecutionPlan

pub fn new(goal: impl Into<String>, complexity: Complexity) -> Self

pub fn add_step(&mut self, step: Task)

pub fn upsert_step(&mut self, step: Task)

Insert or update one step while preserving the plan’s insertion order.

Flow replay can deliver the same durable step definition more than once (for example when an observer is attached during a resumed run). Keeping this operation on the canonical plan prevents each adapter from implementing a subtly different deduplication and status policy.

pub fn add_required_tool(&mut self, tool: impl Into<String>)

pub fn definition_identity( &self, ) -> Result<ExecutionIdentityV1, ExecutionIdentityError>

Derive an identity for the immutable plan definition.

Mutable status is deliberately excluded: restarting or retrying a Flow must keep the same plan identity while its progress changes. The identity contains only already-materialized task definitions and exposes no task output or other runtime evidence. Dynamic Flow adapters bound user-facing descriptions before they enter this projection.

pub fn get_ready_steps(&self) -> Vec<&Task>

Get steps that are ready to execute (dependencies met)

pub fn mark_status(&mut self, step_id: &str, status: TaskStatus)

Update the status of a step by ID

pub fn pending_count(&self) -> usize

Count remaining Pending steps

pub fn has_deadlock(&self) -> bool

Detect deadlock: Pending steps remain but none are ready to execute.

This happens when all Pending steps have dependencies that are not Completed (e.g., circular deps or all deps Failed/Skipped).

pub fn progress(&self) -> f32

Get progress as a fraction (0.0 - 1.0)

Trait Implementations

impl Clone for ExecutionPlan

fn clone(&self) -> ExecutionPlan

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutionPlan

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionPlan

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.