aboutsummaryrefslogtreecommitdiffstats
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/bondallocation_email.py8
1 files changed, 5 insertions, 3 deletions
diff --git a/python/bondallocation_email.py b/python/bondallocation_email.py
index febfa103..d1e42968 100644
--- a/python/bondallocation_email.py
+++ b/python/bondallocation_email.py
@@ -21,7 +21,7 @@ if __name__ == "__main__":
}
df = pd.read_sql_query(
- "SELECT bonds.id as tradeid, trade_date, settle_date, CASE WHEN buysell THEN 'Buy' ELSE 'Sell' end as buysell, identifier, description , faceamount AS notional, price, accrued, principal_payment + accrued_payment as net_amount, name as counterparty, allocation_contacts FROM bonds LEFT JOIN counterparties on cp_code=code where id=2014 and trade_date = %s",
+ "SELECT bonds.id as tradeid, trade_date, settle_date, CASE WHEN buysell THEN 'Buy' ELSE 'Sell' end as buysell, identifier, description , faceamount AS notional, price, accrued, principal_payment + accrued_payment as net_amount, name as counterparty, allocation_contacts FROM bonds LEFT JOIN counterparties on cp_code=code WHERE trade_date = %s and not EMAILED and allocated;",
con=dawndb,
params=(args.trade_date,),
)
@@ -56,8 +56,10 @@ if __name__ == "__main__":
)
em.send_email(
subject=subject,
- # to_recipients=row.allocation_contacts if row.allocation_contacts else ('fyu@lmcg.com,'),
- to_recipients=("fyu@lmcg.com",),
+ to_recipients=row.allocation_contacts
+ if row.allocation_contacts
+ else ("fyu@lmcg.com,"),
+ # to_recipients=("fyu@lmcg.com",),
cc_recipients=cc_recipients,
body=HTMLBody(body),
attach=[