soil.pipeline

This module defines a Pipeline.

Pipeline Objects#

class Pipeline()

A Pipeline stores the transformations and dependencies to obtain certain results.

run#

| run() -> Dict[str, str]

Run the Pipeline (blocking call until the experiment finishes)

add_transformation#

| add_transformation(transformation: Dict[str, str]) -> Pipeline

Add a new transformation to the Pipeline, returns a new Pipeline containing the plan of the old Pipeline plus the transformation.

merge_pipelines#

| @staticmethod
| merge_pipelines(*pipelines: Pipeline) -> Pipeline

Merges all the Pipelines passed into a new Pipeline that is returned.