orchestration_engine.resources#

Definition of dagster data lake resource for acquisition data.

Classes#

DataLakeResource

Dagster data lake resource.

Module Contents#

class orchestration_engine.resources.DataLakeResource#

Bases: dagster.ConfigurableResource

Dagster data lake resource.

get_mrd_path(task_dir: str) → pathlib.Path#

Find the MRD file inside a task directory.

Parameters:

task_dir – Absolute path to the task data directory.

Returns:

Path to the acquisition ISMRMRD file.

Return type:

Path

get_device_parameter(task_dir: str) → tuple[str, dict]#

Read device parameters from device_parameter.json inside a task directory.

Parameters:

task_dir – Absolute path to the task data directory.

Returns:

Device ID and parameter dictionary.

Return type:

tuple[str, dict]