Event-loop based, miniature job queue and worker that runs the task in a subprocess (via fork).
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
ci
src/stampede
tests
.bumpversion.cfg
.cookiecutterrc
.coveragerc
.editorconfig
.gitignore
.travis.yml
AUTHORS.rst
CHANGELOG.rst
CONTRIBUTING.rst
LICENSE
MANIFEST.in
README.rst
setup.cfg
setup.py
tox.ini

README.rst

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