thepipelinetool 0.1.3

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
19
20
21
22
23

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

use thepipelinetool::prelude::*;

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

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