celers-canvas 0.2.0

Workflow primitives for CeleRS (Chain, Chord, Group, Map)
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

//! Canvas workflow primitives
//!
//! This crate provides distributed workflow patterns for task orchestration.
//!
//! # Workflow Primitives
//!
//! - **Chain**: Execute tasks sequentially, passing results as arguments
//! - **Group**: Execute tasks in parallel
//! - **Chord**: Execute tasks in parallel, then run callback with all results
//! - **Map**: Apply a task to multiple argument sets in parallel
//!
//! # Example
//!
//! ```ignore
//! // Chain: task1 -> task2 -> task3
//! let workflow = Chain::new()
//!     .then("task1", args1)
//!     .then("task2", args2)
//!     .then("task3", args3);
//!
//! // Chord: (task1 | task2 | task3) -> callback
//! let workflow = Chord::new()
//!     .add("task1", args1)
//!     .add("task2", args2)
//!     .add("task3", args3)
//!     .callback("aggregate_results", callback_args);
//! ```

mod error;
pub use error::*;

mod signature;
pub use signature::*;

mod chain;
pub use chain::*;

mod group;
pub use group::*;

mod chord;
pub use chord::*;

mod conditional;
pub use conditional::*;

mod canvas_element;
pub use canvas_element::*;

mod error_handling;
pub use error_handling::*;

mod dag_export;
pub use dag_export::*;

mod result_types;
pub use result_types::*;

mod advanced;
pub use advanced::*;

mod checkpoint;
pub use checkpoint::*;

mod compiler;
pub use compiler::*;

mod dependency;
pub use dependency::*;

mod events;
pub use events::*;

mod scheduling;
pub use scheduling::*;

mod streaming;
pub use streaming::*;

mod monitoring;
pub use monitoring::*;

mod visualization;
pub use visualization::*;

mod runtime;
pub use runtime::*;

#[cfg(test)]
mod tests_basic;

#[cfg(test)]
mod tests_advanced;