Skip to main content

run_workflow_with_policy

Function run_workflow_with_policy 

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

Execute the workflow through one executor with an explicit run policy.

ยงErrors

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