pelagos_py.steps

Submodules

• pelagos_py.steps.base_qc
• pelagos_py.steps.base_step
• pelagos_py.steps.input_output
• pelagos_py.steps.processing
• pelagos_py.steps.quality_control
• pelagos_py.steps.templates

pelagos_py.steps.STEP_CLASSES

Dictionary mapping step names to their implementing classes.

pelagos_py.steps.QC_CLASSES

Dictionary mapping QC test names to their implementing classes.

pelagos_py.steps.discover_steps()

Dynamically discover and import step modules from the steps directory. This populates the global STEP_CLASSES and QC_CLASSES registries for use elsewhere.

pelagos_py.steps.resolve_step_name(step_name)

Resolve a step name to its canonical STEP_CLASSES key, case-insensitively (None if no match).

pelagos_py.steps.create_step(step_config, context=None)

Factory to create a Step instance from a dictionary or YAML file.

Parameters:

• step_config (dict | str) –

  • If dict: must contain at least {‘name’: <step_name>}.

  • If str: path to a YAML file describing the step.

• context (dict | None) – Shared context passed through the pipeline.

Returns:

An instantiated, config-aware step.

Return type:

BaseStep