diff options
Diffstat (limited to 'python/client.py')
| -rw-r--r-- | python/client.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/python/client.py b/python/client.py index 5f7ec6d6..6008765c 100644 --- a/python/client.py +++ b/python/client.py @@ -1,8 +1,12 @@ import redis import tasks -from pickle import loads +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]))) |