diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 76a04bff..2194328d 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -234,8 +234,6 @@ if __name__=="__main__": q = get_redis_queue() serenitasdb = dbconn('serenitasdb') dawndb = dbconn('dawndb') - email = EmailMessage('') - email['to'] = 'nyops@lmcg.com' for queue_name in ['bond_trades', 'cds_trades']: list_trades = get_trades(q, queue_name) if list_trades: @@ -244,8 +242,9 @@ 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['to'] = 'nyops@lmcg.com' email['subject'] = email_subject(trade) - email.set_payload(str(trade)) email.send() elif queue_name == 'cds_trades': with init_bbg_session(BBG_IP) as session: |