ProcessorPipeline.run

ProcessorPipeline.run(ds: Dataset) → Dataset

Run all processors sequentially.

Parameters:

ds – Input dataset.

Returns:

The processed xarray dataset.

Raises:

ProcessorPipelineError – If a processor fails and its on_missing is "error".