diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/process_queue.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index fe701dc2..03e9695b 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -312,6 +312,8 @@ def get_trades(q, trade_type="bond", fund="SERCGMAST"): if trades[0]["action"] == "NEW": trades[-1]["action"] = "NEW" list_trades.append(trades[-1]) + if trades[-1]["action"] == "UPDATE": + list_trades.append(trades[-1]) return list_trades @@ -960,5 +962,5 @@ if __name__ == "__main__": upload_file(file_path) except IOError: pass - q.delete(f"{trade_type}_{args.fund}") + q.delete(f"{trade_type}_{args.fund}") dawndb.close() |