stampede 0.0.2

Event-loop based, miniature job queue and worker that runs the task in a subprocess (via fork).

Event-loop based, miniature job queue and worker that runs the task in a subprocess (via fork). When multiple requests are made for the same task they are collapsed into a single instance.

Note:

It doesn’t support arguments to tasks. Not yet …

Usage

class MacLeod(StampedeWorker):
    socket_name = 'test.sock'

    def do_work(self, task_name):
        import time
        time.sleep(18)

man = MacLeod()
man.run()

To create tasks:

echo mytask > nc -U test.sock

Features

• TODO

Implementation

TODO

TODO

• ???

Requirements

OS:

Linux

Runtime:

Python 2.6, 2.7, 3.2, 3.3 or PyPy

Packages:

python-signalfd