aboutsummaryrefslogtreecommitdiffstats
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/bbh_settlements_email.py2
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"