mecfs_bio.build_system.task.xr_pipes.xr_composite

Classes:

• XRCompositePipe –

  Combine multiple XRDataPipes

Attributes:

• logger –

logger module-attribute

logger = get_logger()

XRCompositePipe

Bases: XRDataPipe

Combine multiple XRDataPipes

Methods:

• process –

Attributes:

• pipes (Sequence[XRDataPipe]) –

pipes instance-attribute

pipes: Sequence[XRDataPipe]

process

process(ds: Dataset) -> xr.Dataset

Source code in mecfs_bio/build_system/task/xr_pipes/xr_composite.py

def process(self, ds: xr.Dataset) -> xr.Dataset:
    for pipe in self.pipes:
        logger.debug(f"Running pipe {pipe}")
        ds = pipe.process(ds)
    return ds