diff options
| -rw-r--r-- | python/load_indicative.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/python/load_indicative.py b/python/load_indicative.py index 899e1e1d..90c9ac6f 100644 --- a/python/load_indicative.py +++ b/python/load_indicative.py @@ -2,9 +2,8 @@ import psycopg2 import os import datetime from datetime import date -import csv +import csv, sys, re import pdb -import sys from common import root, sanitize_float from db import conn import logging @@ -85,7 +84,7 @@ def upload_cusip_data(conn, filename): conn.commit() def upload_deal_data(conn, filename): - sqlstr = "select dealname, max(\"Latest Update\") from clo_universe group by dealname" + sqlstr = "select dealname, array_agg(\"Latest Update\") from clo_universe group by dealname" with conn.cursor() as c: c.execute(sqlstr) deallist = dict(c) @@ -122,7 +121,7 @@ def upload_deal_data(conn, filename): dealname = line['Deal/Tranche ID'] line['defaultedbal'] = line["CDO Defaulted Security Balance (Reported)"] line['Deal CUSIP List'] = line['Deal CUSIP List'].split(",") - if dealname not in deallist or line['Latest Update'] > deallist[dealname]: + if dealname not in deallist or line['Latest Update'] not in deallist[dealname]: sqlstring = \ "INSERT INTO clo_universe " \ "VALUES (%(Deal/Tranche ID)s, %(Deal Name)s, %(Collateral Manager)s, %(Orig Deal Bal)s," \ |