diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/process_queue.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 76049ca9..d666e77b 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -20,6 +20,7 @@ from common import get_redis_queue from analytics.utils import previous_twentieth from db import dbconn from send_email import EmailMessage +from tabulate import tabulate HEADERS = {'bond_trades':['Deal Type', 'Deal ID', 'Action', 'Client', 'Reserved', 'Reserved', 'Folder', 'Custodian', 'Cash Account', 'Counterparty', 'Comments', @@ -328,6 +329,10 @@ def email_subject(trade): return "[{0}] {1} {2} {3}".format(trade['asset_class'], trade['action'], "Buy" if trade['buysell'] else "Sell", trade['description']) +def print_trade(trade): + d = trade.copy() + d['buysell'] = "Buy" if d["buysell"] else "Sell" + return tabulate((k, v) for k, v in d.items()) if __name__=="__main__": parser = argparse.ArgumentParser() @@ -343,7 +348,7 @@ if __name__=="__main__": with init_bbg_session(BBG_IP) as session: for trade in list_trades: bond_trade_process(dawndb, session, trade) - email = EmailMessage(str(trade)) + email = EmailMessage(print_trade(trade)) email['to'] = 'nyops@lmcg.com' email['subject'] = email_subject(trade) email.send() |