Struct ExecutionDag 

pub struct ExecutionDag {
    pub nodes: HashMap<String, DagNode>,
    pub ready_nodes: Vec<String>,
    pub dynamic: bool,
}

Execution DAG - supports dynamic modification

Fields

nodes: HashMap<String, DagNode>

All nodes in the DAG

ready_nodes: Vec<String>

Currently ready nodes (in-degree = 0 among non-completed)

dynamic: bool

Whether dynamic modification is allowed

Implementations

impl ExecutionDag

pub fn new() -> ExecutionDag

Create a new empty DAG

pub fn new_dynamic() -> ExecutionDag

Create a dynamic DAG (allows modification during execution)

pub fn from_plan(plan: &Plan) -> Result<ExecutionDag, String>

Build a DAG from a plan

pub fn update_ready_nodes(&mut self)

Update the list of ready nodes

pub fn get_node(&self, id: &str) -> Option<&DagNode>

Get a node by ID

pub fn get_node_mut(&mut self, id: &str) -> Option<&mut DagNode>

Get a mutable node by ID

pub fn mark_running(&mut self, id: &str)

Mark a node as running

pub fn mark_completed(&mut self, id: &str)

Mark a node as completed and update ready nodes

pub fn mark_failed(&mut self, id: &str)

Mark a node as failed

pub fn is_completed(&self) -> bool

Check if all nodes are completed

pub fn has_failed(&self) -> bool

Check if any node has failed

pub fn completed_nodes(&self) -> Vec<&str>

Get all completed node IDs

pub fn failed_nodes(&self) -> Vec<&str>

Get all failed node IDs

pub fn add_node(&mut self, step: Step) -> Result<(), String>

Add a new node dynamically (only if dynamic is enabled)

Trait Implementations

impl Clone for ExecutionDag

fn clone(&self) -> ExecutionDag

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionDag

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

Formats the value using the given formatter.

impl Default for ExecutionDag

fn default() -> ExecutionDag

Returns the “default value” for a type.