diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/load_indicative.py | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/python/load_indicative.py b/python/load_indicative.py index 32017e37..7a7c26e4 100644 --- a/python/load_indicative.py +++ b/python/load_indicative.py @@ -47,7 +47,7 @@ def upload_cusip_data(conn, filename): for key in ['Curr Balance', 'Orig Balance', 'Orig Attachment Point', 'Curr Attachment Point (def at MV)', 'Orig Detachment Point', 'Curr Detachment Point (def at MV)', 'Factor', 'Coupon', - 'Floater Spread/Margin']: + 'Floater Spread']: if line[key]: line[key] = sanitize_float(line[key]) line[key] = convertToNone(line[key]) @@ -65,7 +65,7 @@ def upload_cusip_data(conn, filename): "%(Orig Balance)s, %(Curr Balance)s, %(Factor)s, %(Orig Moody)s, %(Curr Moody)s, " \ "%(Orig Attachment Point)s, %(Orig Detachment Point)s, "\ "%(Curr Attachment Point)s, %(Curr Detachment Point)s, " \ - "%(Floater Index)s, %(Floater Spread/Margin)s, %(updatedate)s)" + "%(Floater Index)s, %(Floater Spread)s, %(updatedate)s)" try: with conn.cursor() as c: c.execute(sqlstring, line) @@ -73,16 +73,16 @@ def upload_cusip_data(conn, filename): logging.error(e) logging.debug("uploaded: {0}".format(line['CUSIP'])) conn.commit() - for dealname in deals_to_update: - with conn.cursor() as c: - c.execute("SELECT p_cusip, p_curr_subordination, "\ - "p_curr_thickness from et_deal_subordination(%s)", - (dealname,)) - data = [ (t[1], t[2], t[0], dealupdate[dealname]) for t in c] - c.executemany("UPDATE cusip_universe SET subordination = %s, " - "thickness = %s WHERE cusip = %s AND " - "updatedate = %s", data) - conn.commit() + # for dealname in deals_to_update: + # with conn.cursor() as c: + # c.execute("SELECT p_cusip, p_curr_subordination, "\ + # "p_curr_thickness from et_deal_subordination(%s)", + # (dealname,)) + # data = [ (t[1], t[2], t[0], dealupdate[dealname]) for t in c] + # c.executemany("UPDATE cusip_universe SET subordination = %s, " + # "thickness = %s WHERE cusip = %s AND " + # "updatedate = %s", data) + # conn.commit() def upload_deal_data(conn, filename): sqlstr = "select dealname, array_agg(\"Latest Update\") from clo_universe group by dealname" |