diff options
| -rw-r--r-- | python/task_server/__init__.py | 1 | ||||
| -rw-r--r-- | python/task_server/rest.py | 4 |
2 files changed, 4 insertions, 1 deletions
diff --git a/python/task_server/__init__.py b/python/task_server/__init__.py index 1b080916..c05d8c27 100644 --- a/python/task_server/__init__.py +++ b/python/task_server/__init__.py @@ -8,5 +8,6 @@ fh.setLevel(logging.INFO) formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s') fh.setFormatter(formatter) loggers = [logging.getLogger('intex'), app.logger] +app.logger.setLevel(logging.INFO) for logger in loggers: logger.addHandler(fh) 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() |