Struct captain_workflow_manager::Scheduler

pub struct Scheduler<ExB: ExecutorBuilder> { /* fields omitted */ }

The entry point of the crate, implementing the job scheduling logic

Example

use captain_workflow_manager::{executor, Scheduler};
let executor = executor::SlurmExecutorBuilder { max_jobs: 10_000 };
let scheduler = Scheduler::new(executor);
scheduler.run(some_jobs)?;

Implementations

impl<ExB: ExecutorBuilder> Scheduler<ExB>

pub fn new(ex_builder: ExB) -> Self

Creates a new scheduler objects, with the provided ExecutorBuilder

Executor builders can be found in the executor module, or custom ones can be implemented.

pub fn run<J: JobUnit>(self, final_job_units: Vec<J>) -> Result<(), Error<J>>

Run each job in final_job_units and its transitive dependencies.

A job won’t be run if its output file is already present. (Currently no finer dependency freshness management is attempted.) Moreover, dependencies of such jobs won’t be run either.