ogdc_runner.inputs module

Code for accessing input data of OGDC recipes

ogdc_runner.inputs.make_fetch_input_template(recipe_config: RecipeConfig, use_pvc: bool = False) → hera.workflows.Container

Creates a container template that fetches multiple inputs from URLs or file paths.

Supports: - HTTP/HTTPS URLs - File paths (including PVC paths) - DataONE datasets

Parameters:

  • recipe_config (RecipeConfig) – Recipe configuration containing input parameters

  • use_pvc (bool) – If True, store inputs on PVC; if False, use Argo artifacts

Return type:

Container

Returns:

Container template configured for input fetching

Raises:

OgdcWorkflowExecutionError – If unsupported input type is encountered

ogdc_runner.inputs.make_pvc_listing_template(pvc_inputs: list[PvcMountInput], partition_size: int, input_pvc_mounts: list[hera.workflows.models.VolumeMount], *, name: str = 'list-pvc-files', image: str | None = None) → hera.workflows.Container

Create a container that enumerates PVC input files at runtime.

The container writes full manifests to the workflow PVC and only exposes compact manifest references as Argo output parameters.

Parameters:
Return type:

Container