thepipelinetool 0.1.1

an *experimental* pipeline orchestration tool drawing on concepts from Apache Airflow
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use std::{time::Duration, vec};

use thepipelinetool::prelude::*;

#[dag]
fn main() {
    let a = add_command(
        json!(["bash", "-c", "sleep 3 && echo hello"]),
        &TaskOptions {
            timeout: Some(Duration::new(2, 0)),
            max_attempts: 2,
            ..Default::default()
        },
    );
    let b = add_command(json!(["echo", a.value()]), &TaskOptions::default());

    let _c = vec![a, b];
}