orchestrator.io.idata_io_manager#

Dagster IO Manager for mrpro IData object.

Classes#

IDataIOManager

IO manager for mrpro IData — writes DICOM files with Dagster run_id as filename prefix.

Module Contents#

class orchestrator.io.idata_io_manager.IDataIOManager#

Bases: orchestrator.io.base.ScanHubIOManager

IO manager for mrpro IData — writes DICOM files with Dagster run_id as filename prefix.

dump_to_path(context: dagster.OutputContext, obj: mrpro.data.IData, path: upath.UPath) None#

Reconstruct IData to DICOM files inside the task directory.

Files are saved as {run_id}_{index:04d}.dcm so that outputs from different Dagster runs of the same pipeline can coexist in the flat task directory and be traced back to a specific run.

load_from_path(context: dagster.InputContext, path: upath.UPath) mrpro.data.IData#

Load IData from the task directory.

load_from_files(files: List[str]) mrpro.data.IData#

Load IData from an explicit file list.