orchestrator.io.base

Base IO Manager for ScanHub resources.

Classes

ScanHubIOManager

Base ConfigurableIOManager for ScanHub — resolves the task directory from dag_config.

Module Contents

class orchestrator.io.base.ScanHubIOManager

Bases: dagster.ConfigurableIOManager

Base ConfigurableIOManager for ScanHub — resolves the task directory from dag_config.

dag_config: orchestrator.utils.dag_config.DAGConfiguration

_get_path() → upath.UPath

handle_output(context: dagster.OutputContext, obj: Any) → None

load_input(context: dagster.InputContext) → Any

abstractmethod dump_to_path(context: dagster.OutputContext, obj: Any, path: upath.UPath) → None

Write obj to path.

abstractmethod load_from_path(context: dagster.InputContext, path: upath.UPath) → Any

Load object from path.

abstractmethod load_from_files(files: List[str]) → Any

Load object from an explicit file list.