cleichner/pipeline — comment on commit 833faf2873c3103fa7fd4190f064ce873cde8048
File: pipeline.py line 59
By cwvh:

Something like this? If so, I like it.

@pipeline(in=5555, out=8888)
def worker():
pass

print "You will see this!"

# local inits are done, spin up the pipeline...
worker.run()