apalis-workflow 0.1.0-rc.7

A flexible and composable task workflow engine for rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// pub struct Composite<SubFlow> {
//     sub_flow: SubFlow,
// }

// impl<L, Input, Output> Step<Input> for Composite<Workflow<Input, Output, L>> {
//     type Response = Output;
//     type Error = Infallible;
//     fn register(&self, ctx: &mut Context<(), ()>) {
//         // TODO
//     }
// }

// impl<Input> Step<Input> for Composite<DagExecutor> {
//     type Response = ();
//     type Error = Infallible;
//     fn register(&self, ctx: &mut StepRouter<()>) {
//         // TODO
//     }
// }