eogrow.utils.pipeline_chain

Module implementing utilities for chained configs.

pydantic model eogrow.utils.pipeline_chain.PipelineRunSchema

Bases: Schema

Create a new model by parsing and validating input data from keyword arguments.

Raises ValidationError if the input data cannot be parsed to form a valid model.

Fields:

• pipeline_config (dict)

• pipeline_resources (Dict[str, Any])

field pipeline_config: dict [Required]

field pipeline_resources: Dict[str, Any] [Optional]

Keyword arguments passed to ray when executing the main pipeline process. The options are specified [here](https://docs.ray.io/en/latest/ray-core/api/doc/ray.remote_function.RemoteFunction.options.html).

eogrow.utils.pipeline_chain.validate_pipeline_chain(pipeline_chain)

Parameters:

pipeline_chain (list[eogrow.core.config.RawConfig]) –

Return type:

None

eogrow.utils.pipeline_chain.run_pipeline_chain(pipeline_chain)

Parameters:

pipeline_chain (list[eogrow.core.config.RawConfig]) –

Return type:

None