diff options
| -rw-r--r-- | python/position_file_bowdst.py | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/python/position_file_bowdst.py b/python/position_file_bowdst.py index 8b4ebd3f..14a29d2a 100644 --- a/python/position_file_bowdst.py +++ b/python/position_file_bowdst.py @@ -8,6 +8,7 @@ from serenitas.utils.remote import SftpClient from serenitas.utils.env import DAILY_DIR from pandas.tseries.offsets import MonthEnd from collections import defaultdict +from serenitas.utils.exchange import ExchangeMessage, FileAttachment def process_upload(trades, asset_type, upload): @@ -23,6 +24,7 @@ def process_upload(trades, asset_type, upload): sftp.put(buf, fname) dest = DAILY_DIR / str(datetime.date.today()) / fname dest.write_bytes(buf) + return fname, buf def build_line(obj, asset_type): @@ -327,5 +329,21 @@ if __name__ == "__main__": positions = { p: list(globals()[f"positions_{p}"](conn, args.date)) for p in args.product } + attachments = [] for asset_type, trades in positions.items(): - process_upload(trades, asset_type, args.u) + fname, buf = process_upload(trades, asset_type, args.u) + attachments.append(FileAttachment(name=fname, content=buf)) + + if args.u: + em = ExchangeMessage() + recipients = ( + "hm-operations@bnymellon.com", + "hedgemark.lmcg.ops@sscinc.com", + "Hedgemark.OTC@sscinc.com", + ) + cc_recipients = ("bowdoin-ops@lmcg.com",) + subject = f"Position_files for Bowdoin Street as of {args.date}" + body = f"Please see monthend positions for Bowdoin Street as of {args.date}" + em.send_email( + subject, body, recipients, cc_recipients=cc_recipients, attach=attachments + ) |