rustvello 0.8.0

Distributed task queue and workflow runtime for Rust and Python: typed tasks, retries, priorities, triggers and pluggable backends
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Runner implementations for Rustvello.
//!
//! This module provides multiple runner types for executing tasks:
//!
//! - [`PersistentTokioRunner`]: Persistent worker pool using tokio tasks (default).
//! - [`RayonRunner`]: Uses rayon thread pool for CPU-bound tasks (feature-gated).
//!
//! [`PersistentTokioRunner::with_subprocess_executor`] swaps the in-process executor for a pool
//! of worker processes (one interpreter per process for Python tasks).
//!
//! The [`TaskRunner`] type alias points to [`PersistentTokioRunner`].

mod attempt;
mod bounded;
mod control_plane;
mod dispatcher;
mod executor;
pub(crate) mod executor_common;
mod persistent_tokio;
#[cfg(feature = "rayon")]
mod rayon_runner;

pub use bounded::ShutdownOutcome;
pub use executor::SubprocessSpec;
pub use persistent_tokio::PersistentTokioRunner;
#[cfg(feature = "rayon")]
pub use rayon_runner::RayonRunner;

/// Alias for the default Tokio-backed runner.
pub type TaskRunner = PersistentTokioRunner;