diff options
Diffstat (limited to 'python/intex/load_intex_collateral.py')
| -rw-r--r-- | python/intex/load_intex_collateral.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/python/intex/load_intex_collateral.py b/python/intex/load_intex_collateral.py index 8e1c3253..78767aa5 100644 --- a/python/intex/load_intex_collateral.py +++ b/python/intex/load_intex_collateral.py @@ -4,7 +4,7 @@ import psycopg2 from .common import sanitize_float from serenitas.utils.env import DATA_DIR import uuid -from .load_indicative import upload_cusip_data, upload_deal_data +from .load_indicative import upload_tranche_data, upload_deal_data import logging logger = logging.getLogger(__name__) @@ -23,6 +23,7 @@ fields = [ "Second Lien", "LoanX ID", "CUSIP", + "FIGI", "Market Price", "Market Price Source", "Market Price Date", @@ -56,6 +57,7 @@ def upload_data(conn, workdate): "SecondLien", "LoanXID", "Cusip", + "figi", "IntexPrice", "IntexPriceSource", "IntexPriceDate", @@ -213,13 +215,13 @@ def upload_data(conn, workdate): def intex_data(conn, workdate): basedir = DATA_DIR / ("Indicative_" + workdate) - cusip_files = [f for f in basedir.iterdir() if "TrInfo" in f.name] + tranche_files = [f for f in basedir.iterdir() if "TrInfo" in f.name] deal_files = [f for f in basedir.iterdir() if "TrInfo" not in f.name] # first load deal data for deal_file in deal_files: upload_deal_data(conn, deal_file) # then load tranche data - for cusip_file in cusip_files: - upload_cusip_data(conn, cusip_file) + for tranche_file in tranche_files: + upload_tranche_data(conn, tranche_file) upload_data(conn, workdate) |