blob: 6008765cfef243a87639fe3bda333fa6946e8492 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
|
import redis
import tasks
from pickle import loads, dumps
q = redis.Redis()
while True:
f, args = loads(q.blpop("tasks")[1])
getattr(tasks, f)(*args)
if f == "build_portfolio":
q.rpush("tasks", dumps(("build_scenarios", args)))
if f == "build_scenarios":
q.rpush("tasks", dumps(("generate_scenarios", args[:-1])))
|
