lw_pipeline.Pipeline

class lw_pipeline.Pipeline(steps, config=None)

Bases: object

Pipeline class to run the pipeline steps.

__init__(steps, config=None)

Initialize the Pipeline.

Parameters:

• steps (list) – A list of step file names or a list of Pipeline_Step instances.

• config (Config, optional) – An instance of Config class, required only if steps are file names

Methods

__init__(steps[, config])	Initialize the Pipeline.
run([data])	Run the pipeline.

run(data=None)

Run the pipeline.

Include all Pipeline_Step classes contained in the step_files list.

Parameters:

data (object, optional) – Optional input data to be passed to the first step.

Returns:

data – The output data after processing through all pipeline steps.

Return type:

object