thepipelinetool 0.2.0

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

use std::vec;

use thepipelinetool::prelude::*;

#[dag]
fn main() {
    let a = add_task(
        bash_operator,
        json!(["bash", "-c", "sleep 2 && echo hello"]),
        &TaskOptions::default(),
    );
    let _ = add_task(
        bash_operator,
        json!(["echo", a.value()]),
        &TaskOptions::default(),
    );
}