somatize-runtime 0.2.21

Execution engine for the Soma computational graph runtime
Documentation 
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
31
32

//! Execution engine for Soma computational graphs.
//!
//! Provides the runtime components that execute compiled plans:
//! - [`GraphSession`] — the primary orchestrator: Graph + filters → compile → execute
//! - [`executor`] — walks [`ExecutionPlan`] trees (sequence, parallel, cached, remote)
//! - [`cache`] — LRU memory cache, local disk cache, tiered cache
//! - [`sampler`] — hyperparameter samplers (Grid, Random, Bayesian/TPE)
//! - [`pruner`] — early stopping strategies (Median, Percentile)
//! - [`stream`] — chunk-based streaming executor
//! - [`StudyRunner`] — orchestrates optimization studies

pub mod cache;
pub mod event_bus;
pub mod executor;
pub mod filter_library;
pub mod graph_session;
pub mod pbt_runner;
pub mod pruner;
pub mod sampler;
pub mod stream;
pub mod study_runner;

pub use cache::{LocalCache, MemoryCache, TieredCache};
pub use event_bus::EventBus;
pub use executor::{Context, GraphInfo, RemoteExecutor, execute, resolve_input};
pub use filter_library::FilterLibrary;
pub use graph_session::{GraphSession, graph_fit, graph_predict, graph_run};
pub use pbt_runner::{FnPbtExecutor, PbtConfig, PbtExecutor, PbtRunner, PopulationMember};
pub use pruner::{MedianPruner, PercentilePruner, Pruner};
pub use sampler::{BayesianSampler, GridSampler, RandomSampler, Sampler};
pub use stream::{FittedFilter, StreamExecutor};
pub use study_runner::{FnTrialExecutor, StudyRunner, TrialExecutor, TrialOutcome};