workflow sample in Celery

workflow_sample.py

"""
Install deps:

$ pip install workflow
$ pip install celery[redis]

Run worker to listen to jobs:

$ cd path/to/this/file/
$ celery -A workflow_sample worker --loglevel=info

Run a job
$ python workflow_sample.py

You will see output of the last task.
"""

from celery import Celery

app = Celery('workflow_sample', broker='redis://localhost:6379/0')

def add(obj, eng):
    obj["value"] += 2

def print_res(obj, eng):
    print obj.get("value")

flow = [add, print_res]

@app.task
def run_workflow(data):
    from workflow.engine import GenericWorkflowEngine
    wfe = GenericWorkflowEngine()
    wfe.setWorkflow(flow)
    wfe.process(data)

if __name__ == "__main__":
    run_workflow.delay([{"value": 10}, {"value": 20}, {"value": 30}])