diff options
Diffstat (limited to 'python/client.py')
| -rw-r--r-- | python/client.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/python/client.py b/python/client.py index 63255412..519b3ea2 100644 --- a/python/client.py +++ b/python/client.py @@ -1,6 +1,6 @@ import redis import tasks -from pickle import loads, dumps +from json import loads, dumps import socket def run(): @@ -11,12 +11,12 @@ def run(): q = redis.Redis(host='debian') while True: - f, args = loads(q.blpop("tasks")[1]) + f, args = loads(q.blpop("tasks")[1].decode('utf-8')) getattr(tasks, f)(*args) if f == "build_portfolio": - q.rpush("tasks", dumps(("build_scenarios", args), protocol=2)) + q.rpush("tasks", dumps(("build_scenarios", args))) if f == "build_scenarios": - q.rpush("tasks", dumps(("generate_scenarios", args[:-1]), protocol=2)) + q.rpush("tasks", dumps(("generate_scenarios", args[:-1]))) if __name__=="__main__": run() |