diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index c5dc819d..e0ebec24 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -378,6 +378,7 @@ def bond_trade_process(conn, session, trade): logging.error('We already have a mark') conn.rollback() +def send_email(trade): # send out email with trade content email = GmailMessage() email.set_content(print_trade(trade)) @@ -478,11 +479,13 @@ if __name__ == "__main__": with init_bbg_session(BBG_IP) as session: for trade in list_trades: bond_trade_process(dawndb, session, trade) + list_trades = [t for t in list_trades if t.get("upload", False)] + for trade in list_trades: + send_email(trade) elif queue_name == 'cds_trades': with init_bbg_session(BBG_IP) as session: for trade in list_trades: cds_trade_process(serenitasdb, dawndb, session, trade) - buf = generate_csv(list_trades, queue_name) file_path = write_buffer(buf, DAILY_DIR, queue_name) if not args.no_upload: |