Struct EnvManager 

pub struct EnvManager { /* private fields */ }

Manages isolated Python environments for pipeline execution.

Implementations

impl EnvManager

pub fn new(base_dir: impl Into<PathBuf>, env_type: EnvType) -> Self

A manager that keeps its environments under base_dir, one per pipeline. The directory is created eagerly; if that fails, EnvManager::ensure_env reports the real error at first use.

pub fn ensure_env( &self, pipeline_id: &str, requirements: &str, ) -> Result<PathBuf>

Get or create an environment for a pipeline. Returns the path to the Python binary.

pub fn cleanup(&self, max_age: Duration) -> usize

Remove unused environments older than max_age.

pub fn env_id_for(requirements: &str) -> String

A stable environment id for a set of requirements.

Callers with no durable pipeline identity — a one-off plan, whose id is a fresh timestamp — must key on this instead. Keying on the plan id gave every plan its own venv and its own pip install, which is unbounded: one short test suite left 17 GB of near-identical environments behind.