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

use std::sync::Arc;

use crate::meta_storage::MetaBackend;
use crate::scheduler::SchedulerHandler;
use crate::schema::SharedProgressMap;
use crate::service::OperonService;
use crate::storage::OperonStorage;

pub(super) struct SchedulerContext<Svc, Sto, MSto>
where
    Svc: OperonService,
    Sto: OperonStorage,
    MSto: MetaBackend,
{
    pub(super) service: Arc<Svc>,
    pub(super) storage: Arc<Sto>,
    pub(super) meta_storage: MSto,
    pub(super) handler: SchedulerHandler<Svc, Sto, MSto>,
    pub(super) progresses: SharedProgressMap,
}