diff options
Diffstat (limited to 'python/task_server/rest.py')
| -rw-r--r-- | python/task_server/rest.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/task_server/rest.py b/python/task_server/rest.py index 97832e00..071fcd29 100644 --- a/python/task_server/rest.py +++ b/python/task_server/rest.py @@ -2,7 +2,7 @@ import psycopg2 from psycopg2.extras import DictCursor import datetime, redis from intex.load_intex_collateral import intex_data -from globeop import download_data +from .globeop import download_data from task_server import app from flask import request, g import json @@ -51,6 +51,8 @@ def run_tasks(): workdate = str(datetime.date.today()) with get_queue().pipeline() as pipe: for dealname, reinvflag in request.form.items(): + app.logger.info("Processing {0} with{1} reinvestment".format(dealname, + "" if reinvflag=="Y" else "out")) pipe.rpush("tasks", json.dumps(("build_portfolio", [workdate, dealname, reinvflag]))) pipe.execute() |