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.