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 40b6cbd4..a5ce2468 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -52,11 +52,11 @@ def build_line(obj): return line def bbg_process(cursor, session, trade): - cursor.execute("SELECT FROM securities WHERE identifier=%s", (trade['identifier'],)) fields = ["MTG_FACTOR_SET_DT", "INT_ACC"] + cursor.execute("SELECT identifier FROM securities WHERE identifier=%s", (trade['identifier'],)) if not cursor.fetchone(): - fields += ["MATURITY", "CRNCY", "NAME", "MTG_FACE_AMT", "FLOATER", - "FLT_SPREAD", "CPN", "CPN_FREQ", "FIRST_CPN_DT", "MTG_PAY_DELAY"] + fields += ["MATURITY", "CRNCY", "NAME", "MTG_FACE_AMT", "FLOATER", + "FLT_SPREAD", "CPN", "CPN_FREQ", "FIRST_CPN_DT", "MTG_PAY_DELAY"] bbg_id = (trade['cusip'] or trade['isin']) + ' Mtge' bbg_type = 'Mtge' |