operon 0.7.0

A workflow engine for parallel, incremental scheduling of DAG-defined multiplex tasks.
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

mod scheduler;
pub(crate) use scheduler::Scheduler;

mod spec;
pub use spec::{
    REBUILD_CONCURRENCY, SchedulerHandler, SpecWithMetadata, TaskHandler, TaskRebuilder, TaskSpec,
    ValidOperon,
};

mod events;
pub(crate) use events::{ControlEvent, ControlEventSender, RunEventInner, SchedulerStateReceiver};
pub use events::{PeerEvent, PeerEventSender, PeerEventSenderMap, PeerEventSenders};

mod options;
pub(crate) use options::SchedulerOptions;

mod error;
pub use error::SchedulerError;

mod individual_scheduler;

mod context;
mod queue;
mod states;