thepipelinetool 0.1.2

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

use thepipelinetool::prelude::*;

fn hi(args: usize) -> Value {
    println!("{}", args);

    json!({ "hello": "world" })
}

#[dag]
fn main() {
    let binding = (0..500).collect::<Vec<usize>>();
    let k: &[usize; 500] = binding.as_slice().try_into().unwrap();
    let _ = expand(hi, k, &TaskOptions::default());
}