diff options
Diffstat (limited to 'python/master.py')
| -rw-r--r-- | python/master.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/master.py b/python/master.py index 982eb3ee..60bea7b4 100644 --- a/python/master.py +++ b/python/master.py @@ -18,6 +18,6 @@ while True: with open(dealsfile) as fh: for line in fh: dealname, reinvflag = line.rstrip().split("\t") - q.rpush("tasks", dumps(("build_portfolio", [workdate, dealname, reinvflag]))) + q.rpush("tasks", dumps(("build_portfolio", [workdate, dealname, reinvflag]), protocol=2)) os.unlink(dealsfile) time.sleep(3) |