Struct Workflow 

pub struct Workflow { /* private fields */ }

A compiled workflow ready for execution.

Created by WorkflowBuilder::build. Execute with run.

Note: Debug is implemented manually because the handler functions are not Debug.

Implementations

impl Workflow

pub async fn run(&self) -> Result<WorkflowResult>

Execute the workflow.

Entry nodes (no incoming edges) run first. Downstream nodes run as their dependencies complete. Nodes sharing the same set of completed dependencies run concurrently via tokio::spawn.

pub async fn run_with_context( &self, ctx: WorkflowContext, ) -> Result<WorkflowResult>

Execute the workflow with a pre-populated context.

pub fn name(&self) -> &str

Get the workflow name.

pub fn entry_nodes(&self) -> &[String]

Get the entry node names.

pub fn node_names(&self) -> &HashSet<String>

Get all node names.

Trait Implementations

impl Debug for Workflow

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

Formats the value using the given formatter.