szal 0.26.3

Workflow engine — step/flow execution with branching, retry, rollback, and parallel stages
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! Sequential deployment pipeline.

use szal::flow::{FlowDef, FlowMode};
use szal::step::StepDef;

fn main() {
    let mut flow = FlowDef::new("deploy-pipeline", FlowMode::Sequential);
    flow.add_step(StepDef::new("build").with_timeout(60_000));
    flow.add_step(
        StepDef::new("test")
            .with_retries(2, 1_000)
            .with_timeout(120_000),
    );
    flow.add_step(StepDef::new("deploy").with_rollback());

    flow.validate().unwrap();
    println!(
        "Flow '{}' validated: {} steps, mode={}",
        flow.name,
        flow.steps.len(),
        flow.mode
    );
    for step in &flow.steps {
        println!(
            "  - {} (timeout={}ms, retries={}, rollback={})",
            step.name, step.timeout_ms, step.max_retries, step.rollbackable
        );
    }
}