Skip to main content

A Pipeline to process an Object Collection

Project description



pipeline-exec is an execution Pipeline to apply to an Object Collection. It's like a group of functions to run on a list of objects. The original goal behind this project was to create a framework to help create a funnel pipeline for Django models instance. We're sure there can be many more uses.


Just run:

  pip install -U pipeline-exec


You need to create a pipeline and add a few funnels to it:

from pipeline_exec.pipeline import Pipe, Pipeline

# creating our funnels
class MyTestPipePlusOne(Pipe):
    def run(self, l):
        return [i + 1 for i in l]

class MyTestPipePlusTwo(Pipe):
    def run(self, l):
        return [i + 2 for i in l]

class MyTestPipeMinusOne(Pipe):
    def run(self, l):
        return [i - 1 for i in l]

# creating our pipeline
pipeline = Pipeline([MyTestPipePlusOne(), MyTestPipePlusTwo(), MyTestPipeMinusOne()])

# run the pipeline[1, 1, 1]) # returns [3, 3, 3]


For now, it's very straight forward. Everyone is welcome to contribute. All pull request are against the develop branch. Unit tests and the flake8 linter run at every push. Thanks in advance for your contribution :)

Project details

Download files

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

Files for pipeline-exec, version 0.4
Filename, size File type Python version Upload date Hashes
Filename, size pipeline_exec-0.4-py3-none-any.whl (4.4 kB) File type Wheel Python version py3 Upload date Hashes View hashes
Filename, size pipeline-exec-0.4.tar.gz (3.1 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page