chemicalchecker.util.pipeline.pipeline.Pipeline

class Pipeline(pipeline_path, config, keep_jobs=False, only_tasks=[], exclude_tasks=[])

Bases: object

Pipeline class.

Run pipelines according to config files.

Initialize a Pipeline instance.

pipeline_path (str): Path where the pipeline will set its structure. keep_jobs (bool): If True temporary job directories will not be

deleted.

Methods

add_task	Add tasks to the pipeline.
clean	Clean all or some of the pipeline steps.
insert_task	Add tasks to the pipeline.
run	Run the pipeline.

add_task(task)

Add tasks to the pipeline.

clean(step=None)

Clean all or some of the pipeline steps.

insert_task(position, task)

Add tasks to the pipeline.

run()

Run the pipeline.