diff options
| -rw-r--r-- | python/process_queue.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index e0ebec24..6c509cd4 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -486,10 +486,11 @@ if __name__ == "__main__": 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: - upload_file(file_path, queue_name) + if list_trades: + buf = generate_csv(list_trades, queue_name) + file_path = write_buffer(buf, DAILY_DIR, queue_name) + if not args.no_upload: + upload_file(file_path, queue_name) q.delete(queue_name) serenitasdb.close() dawndb.close() |