pypeline

Easy-to-use, easy-to-inspect function pipelines for Python

Currently under develop. This is simply a placeholder repository.

construct a pipeline for executing arbitrary Python function using local or distributed schedulers
easily start or stop execution of the pipeline based on named stages
easily start or stop execution based on arbitrary condition
visualize pipeline execution dynamically in a Jupyter notebook or web browswer using Bokeh (super simple version of dask diagnostics dashboard)