Event-loop based, miniature job queue and worker that runs the task in a subprocess (via fork).
Project description
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
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
stampede-0.0.2.tar.gz
(7.5 kB
view hashes)
