tardis.utilities.pipeline module

class tardis.utilities.pipeline.PipelineProcessor(pipeline=None)[source]

Bases: object

add_to_pipeline(func)[source]
async run_pipeline(pipeline_input, *args, **kwargs)[source]
exception tardis.utilities.pipeline.StopProcessing(last_result)[source]

Bases: BaseException

property last_result