src.pipeline.sequential_pipeline

Classes

SequentialPipeline(**kwargs)

class src.pipeline.sequential_pipeline.SequentialPipeline(**kwargs)

Author:

Alberto M. Esmoris Pena

Sequential pipeline (no loops, no recursion). See npu.pipeline.pipeline.Pipeline.

__init__(**kwargs)

Initialize an instance of SequentialPipeline. A sequential pipeline execute the different components in the order they are given. See parent npu.pipeline.pipeline.Pipeline.

Parameters:

kwargs – The attributes for the SequentialPipeline

Variables:

sequence (list) – The sequence of components defining the SequentialPipeline.

build_pipeline_input(**kwargs)

See npu.pipeline.pipeline.Pipeline and npu.pipeline.pipeline.Pipeline.build_pipeline_input().

build_pipeline_output(**kwargs)

See npu.pipeline.pipeline.Pipeline and npu.pipeline.pipeline.Pipeline.build_pipeline_output().

run()

Run the sequential pipeline.

See src.pipeline.sequential_pipeline.SequentialPipeline.run_for_in_pcloud() and src.pipeline.sequential_pipeline.SequentialPipeline.run_for_in_pcloud_concat() .

Returns:

Nothing.

run_for_in_pcloud()

Run the sequential pipeline considering in_pcloud as the input specification.

See src.pipeline.sequential_pipeline.SequentialPipeline.run().

Returns:

Nothing.

run_for_in_pcloud_concat()

Run the sequential pipeline considering in_pcloud_concat as the input specification.

See src.pipeline.sequential_pipeline.SequentialPipeline.run().

Returns:

Nothing.

to_predictive_pipeline(**kwargs)

See Pipeline and src.pipeline.Pipeline.to_predictive_pipeline().

is_using_deep_learning()

A sequential pipeline is said to use deep learning if it contains at least one ModelOp which is based on a deep learning model.

See npu.pipeline.pipeline.Pipeline.is_using_deep_learning().

write_deep_learning_model(path)

Write the deep learning models contained in the sequential pipeline.

See npu.pipeline.pipeline.Pipeline.write_deep_learning_model().

validate_attributes()

See npu.pipeline.Pipeline and npu.pipeline.Pipeline.validate_attributes().

populate_sequence(seq_pipeline)

See npu.pipeline.sequential_pipeline.SequentialPipeline and npu.pipeline.sequential_pipeline.SequentialPipeline.populate_sequence().

build_executor(input, output)

See npu.sequential_pipeline.SequentialPipeline and npu.sequential_pipeline.SequentialPipeline.build_executor().

pre_run_case(input, output)

This method can be overridden to provide additional logic that must be run before running the current case logic.

See npu.pipeline.sequential_pipeline.SequentialPipeline.run_case().

Returns:

Nothing at all.

post_run_case(input, output)

This method can be overridden to provide additional logic that must be run after running the current case logic.

See npu.pipeline.sequential_pipeline.SequentialPipeline.run_case().

Returns:

Nothing at all.