Skip to main content

run_workflow

Function run_workflow 

Source
pub async fn run_workflow<E: NodeExecutor + ?Sized>(
    workflow: &WorkflowDefinition,
    execution: &ExecutionMetadata,
    executor: &E,
) -> Result<()>
Expand description

Execute the workflow by invoking the provided executor for each node.

ยงErrors

Returns an error if the default run policy rejects the workflow shape or any node execution fails.