diff options
| -rw-r--r-- | python/process_queue.py | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 33c229e7..27d35ba5 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -12,6 +12,12 @@ import sys from io import StringIO from analytics import CreditIndex + +try: + from env import DAILY_DIR +except KeyError: + sys.exit("Please set path of daily directory in 'DAILY_DIR'") + from exchange import ExchangeMessage, FileAttachment from itertools import groupby from pickle import loads @@ -1014,11 +1020,6 @@ if __name__ == "__main__": parser.add_argument("fund", nargs="?", default="SERCGMAST") args = parser.parse_args() r = get_redis_queue() - try: - from env import DAILY_DIR - except KeyError: - sys.exit("Please set path of daily directory in 'DAILY_DIR'") - dawndb = dbconn("dawndb") with init_bbg_session(BBG_IP) as session: for trade_type in [ |