contrib/spoolqueue/tasks.py


1
2
3
4
5
6
7
8
9

from tasksconsumer import *

@queueconsumer('fast', 4)
def fast_queue(arguments):
    print "fast", arguments

@queueconsumer('slow')
def slow_queue(arguments):
    print "foobar", arguments