Struct DagWorkflowEngine 

pub struct DagWorkflowEngine { /* private fields */ }

Lightweight DAG workflow engine.

Executes nodes in topological order. For each node it calls the registered executor closure (if any) and tracks per-node status.

Implementations

impl DagWorkflowEngine

pub fn new() -> Self

Create an engine without an executor (nodes are marked Completed immediately).

pub fn with_executor<F>(self, f: F) -> Self

where F: Fn(&mut WorkflowNode) -> Result<(), String> + Send + Sync + 'static,

Attach a node executor closure.

pub fn execute(&self, dag: &mut WorkflowDag) -> Result<DagRunStatus, DagError>

Execute a DAG and return a status snapshot.

Errors

Returns a DagError if the DAG contains a cycle.

pub fn node_status(&self, node_id: NodeId) -> Option<NodeStatus>

Get the current status of a node (across all runs).

Trait Implementations

impl Default for DagWorkflowEngine

fn default() -> Self

Returns the “default value” for a type.