diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 53064509..76a04bff 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -18,6 +18,7 @@ import re from db import dbconn import logging import argparse +import psycopg2 from send_email import EmailMessage def decode_dict(d): @@ -221,6 +222,11 @@ def write_buffer(buf, queue_name='bond_trades'): fh.write(buf) return timestamp +def email_subject(trade): + return "[{0}] {1} {2} {3}".format(trade.asset_class, trade.action, + "Buy" if trade.buysell else "Sell", + trade.description) + if __name__=="__main__": parser = argparse.ArgumentParser() parser.add_argument("-n", "--no-upload", action="store_true", help="do not upload to Globeop") @@ -229,7 +235,7 @@ if __name__=="__main__": serenitasdb = dbconn('serenitasdb') dawndb = dbconn('dawndb') email = EmailMessage('') - email['to'] = 'guillaume.horel@gmail.com' + email['to'] = 'nyops@lmcg.com' for queue_name in ['bond_trades', 'cds_trades']: list_trades = get_trades(q, queue_name) if list_trades: @@ -238,7 +244,7 @@ if __name__=="__main__": with init_bbg_session(BBG_IP) as session: for trade in list_trades: bond_trade_process(dawndb, session, trade) - email['subject'] = 'test' + email['subject'] = email_subject(trade) email.set_payload(str(trade)) email.send() elif queue_name == 'cds_trades': |