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

use std::vec;

use thepipelinetool::prelude::*;

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