Skip to main content

A package that loads a module as a callable pipeline.

Project description

modpipe: modules as pipelines Documentation Status Updates

A package that loads a module as a callable pipeline.

Auxillary Functions

By default, underscore-prefixed callable do not enter the pipeline. Semantically, they are auxiliary functions.

Assert Your Expectations

Use assertions liberally for top level code in each module (i.e. pipeline. Changes to expectations should fail loudly at import time.

def sqrt(x):
    return type(x)(x ** 0.5)

assert sqrt(1764) == 42, "Uh oh!"


  • If your function returns None, the pipeline assumes you modified the function arguments in place and the next function in the pipeline receives the same function arguments, rather than none.

  • If you want to return None, return the Done(None) from your function.

  • If you process a value and want to skip processing until another function, return SkipTo(f2, arg1, arg2).

The pipeline is mostly a sequence of function applications. SkipTo makes trivial DAGs easy to implement and hard ones challenging. This is a feature, not a bug. Complicated DAGs makes reasoning about your data challenging. The best solution is to compose near-decomposable pipelines as modules, with custom processing in the joins.

Simplifying assumptions

I’m sure this is going to bite me in the ass, but if you return a tuple from a function and that tuple’s size matches the arity of the next function in the pipeline, it does f(*res). Otherwise, it does f(res). Keyword arguments don’t work.


I think this was inspired by PyMC3.


0.0.1 (2018-04-30)

  • First release on PyPI.

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

modpipe-0.0.1.tar.gz (11.0 kB view hashes)

Uploaded source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page