retools queue and worker

gistfile1.py

# queue.py run from the commandline
import time
from retools.queue import QueueManager


def insanely_slow_function(num=0):
    previous = 1
    for i in range(1, num):
        previous = previous + i
    return previous

qm = QueueManager()

while(True):
    qm.enqueue('dummyapp.queue:insanely_slow_function', num=100000000)
    print("I just ran!")
    time.sleep(40)

#insanely_slow_function(num=100000000)

#
# Then I just call retools-worker in another terminal
#

queue.py run from the commandline

import time
from retools.queue import QueueManager

def insanely_slow_function(num=0):
previous = 1
print "running job"
for i in xrange(1, num):
previous = previous + i
print "done with job"
return previous

qm = QueueManager()

if name == 'main':
while(True):
qm.enqueue('code:insanely_slow_function', num=100000000)
print("I just ran!")
time.sleep(40)

insanely_slow_function(num=100000000)

Then I just call retools-worker in another terminal