Overview
docs | |docs| |
---|---|
tests | |
package |
A really simple job queue. Uses a rudimentary event loop and runs tasks in subprocesses (managed with signalfd). Doesn't support task arguments. Task results are rudimentary (only succcess or failure with exit code). When multiple requests are made for the same task they are collapsed into a single request.
- Free software: BSD 2-Clause License
Installation
pip install stampede
Documentation
To use the project:
import stampede
class MyWorker(StampedeWorker):
def handle_task(self, name):
print("Perfoming work for task:", name)
Development
To run the all tests run:
tox