thepipelinetool 0.2.3

readers used for thepipelinetool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use thepipelinetool_core::dev::{get_edges, get_tasks, Task};
use thepipelinetool_utils::run_bash_command;

pub fn read_from_executable(dag_name: &str) {
    let tasks_from_json: Vec<Task> = serde_json::from_value(run_bash_command(
        &[dag_name, "describe", "tasks"],
        true,
        true,
    ))
    .unwrap();

    for task in tasks_from_json {
        get_tasks().write().unwrap().insert(task.id, task);
    }

    let edges_from_json: Vec<(usize, usize)> = serde_json::from_value(run_bash_command(
        &[dag_name, "describe", "edges"],
        true,
        true,
    ))
    .unwrap();

    for edge in edges_from_json {
        get_edges().write().unwrap().insert(edge);
    }
}