ez_azml.cloud_runs.pipelines.pipeline.PipelineRun

class ez_azml.cloud_runs.pipelines.pipeline.PipelineRun(experiment_name: str, commands: dict[str, ez_azml.cloud_runs.commands.command.CommandRun], pipeline: Callable, dec_kwargs: dict[str, Any] | None = None, register_components: bool = False, **kwargs)

Bases: CloudRun

Cloud run that uses mldesigner pipelines.

Parameters:

• experiment_name – experiment this pipeline is associated with

• commands – commands to use within the pipeline

• pipeline – function representing the pipeline

• dec_kwargs – kwargs for azure.ai.ml.dsl.pipeline decorator

__init__(experiment_name: str, commands: dict[str, ez_azml.cloud_runs.commands.command.CommandRun], pipeline: Callable, dec_kwargs: dict[str, Any] | None = None, register_components: bool = False, **kwargs) → None

Methods

__init__(experiment_name, commands, pipeline)
on_register_end()	Hook called after a component has been registered.
on_register_start()	Hook called before a component has been registered.
on_run_end(output)	Hook called once run has been submitted.
on_run_start()	Hook called before run is submitted.
register()	Registers the run as a reusable component.
run()	Submits and runs the job.