Skip to main content

Crate jamjet_scheduler

Crate jamjet_scheduler 

Source
Expand description

JamJet Scheduler

The scheduler drives workflow execution:

  1. Detect which nodes are runnable (all predecessors completed)
  2. Dispatch runnable nodes to the appropriate worker queue
  3. Monitor worker leases and re-queue timed-out items
  4. Handle retry scheduling on node failure
  5. Wake suspended executions on timer/external-event

Re-exports§

pub use runner::Scheduler;
pub use runner::SchedulerConfig;

Modules§

runner
strategy_bridge