Improve work generator.

This commit is contained in:
Vincent Driessen 2012-02-10 18:32:59 +01:00
parent 791f8169f5
commit 63ef198fd6
2 changed files with 11 additions and 4 deletions

View File

@ -18,10 +18,7 @@ def main():
use_redis() use_redis()
#funcs = filter(lambda s: not s.startswith('_'), dir(rq.dummy)) queues = ('default', 'high', 'low')
#print(funcs)
queues = ('default', 'high', 'normal', 'low')
sample_calls = [ sample_calls = [
(dummy.do_nothing, [], {}), (dummy.do_nothing, [], {}),
@ -30,6 +27,10 @@ def main():
(dummy.do_nothing, [], {}), (dummy.do_nothing, [], {}),
(dummy.do_nothing, [], {}), (dummy.do_nothing, [], {}),
(dummy.sleep, [1], {}), (dummy.sleep, [1], {}),
(dummy.fib, [8], {}), # normal result
(dummy.fib, [24], {}), # takes pretty long
(dummy.div_by_zero, [], {}), # 5 / 0 => div by zero exc
(dummy.fib, [30], {}), # takes long, then crashes
] ]
for i in range(opts.count): for i in range(opts.count):

View File

@ -21,6 +21,12 @@ def endless_loop():
def div_by_zero(): def div_by_zero():
1/0 1/0
def fib(n):
if n <= 1:
return 1
else:
return fib(n-2) + fib(n-1)
def yield_stuff(): def yield_stuff():
yield 7 yield 7
yield 'foo' yield 'foo'