diff options
| -rw-r--r-- | python/mtm_status.py | 35 |
1 files changed, 17 insertions, 18 deletions
diff --git a/python/mtm_status.py b/python/mtm_status.py index 0650b9f7..1d61bfc5 100644 --- a/python/mtm_status.py +++ b/python/mtm_status.py @@ -42,24 +42,23 @@ def run(conn, date): except UniqueViolation: conn.rollback() else: - pass - # if (row.SwapType == "NEW") and (row.BrokerId != "BNPBNY") and cpty_id: - # if row.ProductType == "CDISW": - # c.execute( - # "UPDATE swaptions SET cpty_id = %s WHERE dealid = %s", - # ( - # cpty_id, - # row.TicketNo, - # ), - # ) - # elif row.ProductType == "TRN": - # c.execute( - # "UPDATE cds SET cpty_id = %s WHERE dealid = %s", - # ( - # cpty_id, - # row.TicketNo, - # ), - # ) + if (row.SwapType == "NEW") and (row.BrokerId != "BNPBNY") and cpty_id: + if row.ProductType == "CDISW": + c.execute( + "UPDATE swaptions SET cpty_id = %s WHERE dealid = %s", + ( + cpty_id, + row.TicketNo, + ), + ) + elif row.ProductType == "TRN": + c.execute( + "UPDATE cds SET cpty_id = %s WHERE dealid = %s", + ( + cpty_id, + row.TicketNo, + ), + ) conn.commit() |