pipelines.runners.eager module#

class pipelines.runners.eager.Runner#

Bases: PipelineRunner

Runs each tasks synchronously. This should only be used for development and is not intended for a production environment.

run(pipeline_execution: PipelineExecution, reporter: PipelineReporter) → bool#

Runs each task synchronously returning True when all tasks have completed successfully or returning False (or raising an error) if any fail.

Parameters:

  • pipeline_execution – The pipeline execution object representing the pipeline to run.

  • reporter – The reporter object to write messages to.