apalis-workflow 1.0.0

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
20
21
22
23
24
25
26
27
28
29
30

// use std::str::FromStr;

// use apalis_core::{
//     backend::{Backend, BackendConfig, WireFormatBackend},
//     error::BoxDynError,
// };

// use crate::{
//     GraphFlow, SteppedFlow, SteppedService,
//     sequential::{Stack, Step, router::WorkflowRouter},
// };

// impl<Cur, B> Step<Cur, B> for GraphFlow<B>
// where
//     B: Backend + WireFormatBackend + BackendConfig,
//     B::Compact: Send + Sync + 'static,
// {
//     type Response = Res;

//     type Error = B::Error;

//     fn register(&mut self, router: &mut WorkflowRouter<B>) -> Result<(), BoxDynError> {
//         let svc = self.build()?;
//         let end_nodes = svc.end_nodes;
//         let svc = SteppedService::<B::Compact>::new(svc);
//         let count = router.steps.len();
//         router.steps.insert(count, svc);
//         Ok(())
//     }
// }