pelagos_py.steps.base_step#

pelagos_py.steps.base_step.REGISTERED_STEPS[source]#: Registry of explicitly registered step classes.

pelagos_py.steps.base_step.register_step(cls)[source]#: Decorator to mark a step class for inclusion in the pipeline.

class pelagos_py.steps.base_step.BaseStep(name, parameters=None, diagnostics=False, context=None)[source]#

Bases: pelagos_py.utils.config_mirror.ConfigMirrorMixin

Base class for pipeline steps with config-mirroring support. Every concrete subclass (registered via @register_step) inherits this.

classmethod describe_parameters()[source]#

Return a JSON-serialisable description of this step’s parameters.

Introspection surface for external tools (e.g. a dashboard) that need to render a parameter form without instantiating the step. See pelagos_py.utils.parameter_spec.describe().

log(message)[source]#: Log an info-level message with step name prefix.

log_warn(message, warning_type=UserWarning)[source]#: Log a warning-level message with step name prefix.

check_data()[source]#: Check for data in context for transformer steps.

update_parameters(**kwargs)[source]#

Update parameter values both in attributes and in private store.

Example:

self.update_parameters(file_path='newfile.nc', add_meta=False)

generate_config()[source]#: Return this step’s config dict (suitable for saving to YAML).

save_config(path: str | None = None)[source]#: Save this step’s config to YAML (for standalone debugging).