diff options
| -rw-r--r-- | python/process_queue.py | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 26f1b819..53064509 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 +from send_email import EmailMessage def decode_dict(d): return {k.decode() if isinstance(k, bytes) else k: \ @@ -94,7 +95,7 @@ def get_bbg_data(conn, session, identifier, cusip=None, isin = None, settle_date if data[bbg_id]: break else: - logging.error('{0} not in bloomberg'.format(cusip_or_ising)) + logging.error('{0} not in bloomberg'.format(cusip_or_isin)) return bbg_data = data[bbg_id] @@ -227,6 +228,8 @@ if __name__=="__main__": q = get_redis_queue() serenitasdb = dbconn('serenitasdb') dawndb = dbconn('dawndb') + email = EmailMessage('') + email['to'] = 'guillaume.horel@gmail.com' for queue_name in ['bond_trades', 'cds_trades']: list_trades = get_trades(q, queue_name) if list_trades: @@ -235,9 +238,13 @@ 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.set_payload(str(trade)) + email.send() elif queue_name == 'cds_trades': with init_bbg_session(BBG_IP) as session: - l = [cds_trade_process(serenitasdb, dawndb, session, trade) for trade in list_trades] + list_trades = [cds_trade_process(serenitasdb, dawndb, session, trade) \ + for trade in list_trades] buf = generate_csv(list_trades, queue_name) timestamp = write_buffer(buf, queue_name) if not args.no_upload and queue_name!='cds_trades': |