Struct WorkflowEngine 

pub struct WorkflowEngine;

Executes workflows by resolving the DAG and running steps.

Independent steps are executed in parallel using tokio tasks.

Implementations

impl WorkflowEngine

pub fn new() -> Self

Creates a new workflow engine.

pub async fn run( &self, workflow: Workflow, ) -> Result<WorkflowContext, WorkflowError>

Runs a workflow to completion.

Steps are executed in parallel groups determined by the DAG. If any step fails, dependent steps are skipped and the error is returned.

pub async fn run_with_checkpoint( &self, workflow: Workflow, checkpoint_path: &Path, ) -> Result<WorkflowContext, WorkflowError>

Runs a workflow with checkpointing after each group completes.

If a checkpoint file already exists at the path, completed steps are skipped.

Trait Implementations

impl Clone for WorkflowEngine

fn clone(&self) -> WorkflowEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowEngine

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

Formats the value using the given formatter.

impl Default for WorkflowEngine

fn default() -> WorkflowEngine

Returns the “default value” for a type.