Struct ResultsDir 

pub struct ResultsDir { /* private fields */ }

Implementations

impl ResultsDir

pub fn open(root: &Path) -> Result<Self, ResultsError>

Opens the folder, creating it if needed.

pub fn root(&self) -> &Path

pub fn store(&self) -> &ZarrStore

pub fn save_run( &self, pipeline: &str, recording: &str, manifest: &RunManifest, ) -> Result<(), ResultsError>

pub fn save_summary( &self, summary: &BatchSummary, ) -> Result<PathBuf, ResultsError>

pub fn run_batch( &self, plan: &Plan, source: &dyn InputSource, shard: Option<(usize, usize)>, workers: usize, on_done: &(dyn Fn(&RecordingRun) + Sync), ) -> Result<BatchSummary, ResultsError>

Runs plan over the recordings in ids (all when None), saving each run as it finishes and a summary at the end. on_done sees each recording for progress.

pub fn pipelines(&self) -> Vec<String>

pub fn recordings(&self, pipeline: &str) -> Vec<String>

Recordings with a saved run, sorted.

pub fn manifest( &self, pipeline: &str, recording: &str, ) -> Result<RunManifest, ResultsError>

pub fn output( &self, pipeline: &str, recording: &str, reference: &str, ) -> Result<Arc<Artifact>, ResultsError>

A step output, by step.output, or by step when it has one output.

pub fn export_hdf5( &self, pipeline: &str, dir: &Path, ) -> Result<Vec<PathBuf>, ResultsError>

Writes one HDF5 file per recording to dir, for MATLAB and other tools.