Lightweight task processing queue.
Project description
sisyphus
========
lightweight celery replacement. Project needs love.
Installation
------------
git clone https://github.com/mkorenkov/sisyphus.git
cd sisyphus
python setup.py install
Pip package pending.
Defining tasks
--------------
import time
from sisyphus.decorators import stone, stone2
@stone
def hello_world():
print "Hello world"
@stone
def print_value(value):
print value
@stone
def long_run():
print "sleeping..."
time.sleep(30)
print "stop sleeping"
Scheduling tasks
----------------
hello_world().delay()
print_value(14).delay()
long_run().delay()
print_value(21).delay()
Running a worker
----------------
from sisyphus.master import Master
if __name__ == "__main__":
m = Master()
m.run()
========
lightweight celery replacement. Project needs love.
Installation
------------
git clone https://github.com/mkorenkov/sisyphus.git
cd sisyphus
python setup.py install
Pip package pending.
Defining tasks
--------------
import time
from sisyphus.decorators import stone, stone2
@stone
def hello_world():
print "Hello world"
@stone
def print_value(value):
print value
@stone
def long_run():
print "sleeping..."
time.sleep(30)
print "stop sleeping"
Scheduling tasks
----------------
hello_world().delay()
print_value(14).delay()
long_run().delay()
print_value(21).delay()
Running a worker
----------------
from sisyphus.master import Master
if __name__ == "__main__":
m = Master()
m.run()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
sisyphus-0.0.1.3.tar.gz
(6.9 kB
view hashes)