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
pub(crate) type IndividualControlEventReceiver =
    tokio::sync::mpsc::Receiver<IndividualControlEvent>;
pub(crate) type IndividualControlEventSender = tokio::sync::mpsc::Sender<IndividualControlEvent>;

/// `IndividualScheduler`-`Scheduler` communication events.
///
/// These events are produced when `Scheduler` handles
/// [`ControlEvent`](crate::scheduler::events::IndividualControlEvent), where appropriate events are
/// multiplexed to the
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum IndividualControlEvent {
    Pause,
    /// Resume executing new jobs.
    Resume,
    Quit {
        force: bool,
    },
}