dagrs 0.8.1

Dagrs follows the concept of Flow-based Programming and is suitable for the execution of multiple tasks with graph-like dependencies. Dagrs has the characteristics of high performance and asynchronous execution. It provides users with a convenient programming interface.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

pub mod connection;
pub mod graph;
pub mod node;
pub mod utils;

pub use connection::{
    in_channel::InChannels, information_packet::Content, out_channel::OutChannels,
};
pub use graph::error::{DagrsError, DagrsResult, ErrorCode, ErrorContext};
pub use node::*;

pub use async_trait;
pub use graph::*;
pub use tokio;
pub use utils::checkpoint::{
    Checkpoint, CheckpointConfig, CheckpointId, CheckpointStore, FileCheckpointStore,
    MemoryCheckpointStore, NodeExecStatus, NodeState, StoredOutputKind,
};
pub use utils::{env::EnvVar, output::Output};

#[cfg(feature = "derive")]
pub use dagrs_derive::*;