diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/process_queue.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 6f6ad464..1d9870c5 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -337,7 +337,7 @@ def get_bbg_data( asset_class=None, **kwargs, ): - fields = ["MTG_FACTOR_SET_DT", "INT_ACC"] + fields = ["MTG_FACTOR_SET_DT", "INT_ACC", "ISSUER"] fields_dict = { "Mtge": ["MTG_FACE_AMT", "START_ACC_DT"], "Corp": ["AMT_ISSUED", "PREV_CPN_DT"], @@ -398,6 +398,7 @@ def get_bbg_data( "bbg_type", "asset_class", "start_accrued_date", + "issuer", ] placeholders = ",".join(["%s"] * len(sql_fields)) columns = ",".join(sql_fields) @@ -434,6 +435,7 @@ def get_bbg_data( bbg_type, asset_class, bbg_data.get("START_ACC_DT") or bbg_data.get("PREV_CPN_DT"), + bbg_data["ISSUER"], ), ) conn.commit() |