run#

Defined in: voxatlas.pipeline.pipeline

VoxAtlasPipeline.run()[source]#

Execute the configured feature graph and return computed outputs.

The pipeline validates the requested features, creates an execution plan from registry dependencies, then executes each dependency layer in order. Intermediate outputs are inserted into a feature store so later features can retrieve them.

Returns:

Store containing requested features and any computed dependencies.

Return type:

FeatureStore

Raises:

  • ValueError – Raised when the dependency graph contains a cycle.

  • KeyError – Raised when a required feature is missing from the store or cache during execution.

Notes

When caching is enabled, cached outputs are loaded before an extractor is scheduled for execution.

Examples

>>> import numpy as np
>>> from voxatlas.audio.audio import Audio
>>> from voxatlas.pipeline import Pipeline
>>> audio = Audio(waveform=np.zeros(16000, dtype=np.float32), sample_rate=16000)
>>> pipeline = Pipeline(
...     audio=audio,
...     units=None,
...     config={"features": ["acoustic.pitch.dummy"], "pipeline": {"n_jobs": 1, "cache": False}},
... )
>>> results = pipeline.run()
>>> results.exists("acoustic.pitch.dummy")
True