Struct DagWorkflow 

pub struct DagWorkflow;

WorkflowPort backed by petgraph directed graphs.

Implementations

impl DagWorkflow

pub fn new() -> Self

Create a new workflow engine.

Trait Implementations

impl Clone for DagWorkflow

fn clone(&self) -> DagWorkflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DagWorkflow

impl Debug for DagWorkflow

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

Formats the value using the given formatter.

impl Default for DagWorkflow

fn default() -> DagWorkflow

Returns the “default value” for a type.

impl WorkflowPort for DagWorkflow

fn validate_acyclic(&self, workflow: &Workflow) -> Result<()>

Validate the workflow is acyclic; reject cycles.

fn topological_order(&self, workflow: &Workflow) -> Result<Vec<String>>

Return a topological execution order (dependencies first).

fn ready_set( &self, workflow: &Workflow, completed: &[String], ) -> Result<Vec<String>>

Return node ids whose dependencies are all in completed and not yet done.