Struct ParallelSteps 

pub struct ParallelSteps {
    pub name: String,
    pub steps: Vec<WorkflowStep>,
    pub fail_fast: bool,
}

A named group of steps that execute concurrently.

Fields

name: String

Group name (for logging and error messages).

steps: Vec<WorkflowStep>

The steps in this group.

fail_fast: bool

When true (the default): return an error as soon as the first failure is detected rather than waiting for all steps to finish.

Note: because this implementation uses std::thread::scope, all spawned threads must complete before the scope returns regardless of fail_fast. The flag controls only whether the error type returned is ParallelStepError::StepFailed (single, fail-fast) or ParallelStepError::MultipleStepsFailed (aggregated).

Implementations

impl ParallelSteps

pub fn new(name: impl Into<String>) -> Self

Create a new group with fail_fast = true and no steps.

pub fn with_fail_fast(self, fail_fast: bool) -> Self

Set the fail_fast flag.

pub fn add_step(&mut self, step: WorkflowStep) -> &mut Self

Append a step to the group.

pub fn execute_parallel(&self) -> Result<Vec<StepResult>, ParallelStepError>

Execute all steps in parallel using std::thread::scope.

All worker threads are joined before this function returns. Results are collected in the same order as Self::steps.

Errors

Returns ParallelStepError::StepFailed if fail_fast = true and one or more steps fail, or ParallelStepError::MultipleStepsFailed if fail_fast = false and multiple steps fail.