diff options
| -rw-r--r-- | python/bbh_settlements_email.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/bbh_settlements_email.py b/python/bbh_settlements_email.py index 30264eec..265a1e16 100644 --- a/python/bbh_settlements_email.py +++ b/python/bbh_settlements_email.py @@ -73,7 +73,7 @@ def check_trade_settlements(date, fund, conn): net_amount = 0 match row.asset_class: case "TRANCHE_CF": - sql_query = "SELECT cds.dealid as serenitas_id, cds.cpty_id as counterparty_id, coalesce(principal,0) + coalesce(accrued,0) as payment_amount FROM tranche_cashflows LEFT JOIN cds ON tranche_id=cds.id WHERE tranche_id in %s AND date=%s" + sql_query = " SELECT dealid AS serenitas_id, cpty_id AS counterparty_id, total_cashflow AS payment_amount FROM tranche_cashflow_settlements tcs WHERE id IN %s AND settle_date=%s;" case "TRANCHE": sql_query = "SELECT ct.dealid as serenitas_id, c.cpty_id as counterparty_id, ct.upfront as payment_amount FROM cds_trades ct LEFT JOIN cds c USING (id) WHERE ct.id in %s AND ct.settle_date = %s" |