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

use crate::scheduler::SchedulerError;

/// `IndividualScheduler`-worker communication events.
///
/// These are used for communication between individual schedulers and their
/// child worker coroutines.
#[derive(Debug)]
pub(crate) enum InternalEvent<J, R, UErr, SErr, MErr> {
    /// A job successfully finished.
    JobSuccess(J, R),
    /// A job failed.
    JobFailure(J, SchedulerError<UErr, SErr, MErr>),
}