diff options
Diffstat (limited to 'python/task_server/rest.py')
| -rw-r--r-- | python/task_server/rest.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/task_server/rest.py b/python/task_server/rest.py index d0752765..5f0805be 100644 --- a/python/task_server/rest.py +++ b/python/task_server/rest.py @@ -54,7 +54,7 @@ def run_tasks(): for dealname, reinvflag in request.form.items(): app.logger.info("Processing {0} with{1} reinvestment".format(dealname, "" if reinvflag=="TRUE" else "out")) - pipe.rpush("tasks", json.dumps(("build_portfolio", - [workdate, dealname, reinvflag]))) + pipe.rpush("tasks", json.dumps({"fun": "build_portfolio", + "args": [workdate, dealname, reinvflag]})) pipe.execute() return '', 200 |
