diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 4b083df5..4a387aa8 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -13,7 +13,7 @@ from ftplib import FTP import config import os from sqlalchemy import create_engine -from bbg_helpers import init_bbg_session, retreive_data +from bbg_helpers import init_bbg_session, retrieve_data import re def decode_dict(d): @@ -63,11 +63,11 @@ def bbg_process(cursor, session, trade): bbg_id = (trade['cusip'] or trade['isin']) + ' Mtge' bbg_type = 'Mtge' - data = retreive_data(session, [bbg_id], fields, overrides={'SETTLE_DT': trade['settle_date']}) + data = retrieve_data(session, [bbg_id], fields, overrides={'SETTLE_DT': trade['settle_date']}) if not data[bbg_id]: bbg_id = (trade['cusip'] or trade['isin']) + ' Corp' bbg_type = 'Corp' - data = retreive_data(session, [bbg_id], fields, overrides={'SETTLE_DT': trade['settle_date']}) + data = retrieve_data(session, [bbg_id], fields, overrides={'SETTLE_DT': trade['settle_date']}) bbg_data = data[bbg_id] if bbg_data.get('MTG_FACTOR_SET_DT', 0) == 0: |