diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 1bf80adc..4a0e0bdd 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -75,14 +75,11 @@ def process_indicative( ) for trade in get_trades(p, trade_type): process_fun(conn, session, trade) - if trade_type == "bond": - continue - else: - fund = trade["fund"] - if trade.get("upload", True) and ( - fund in ("SERCGMAST", "BOWDST") or trade_type in ("cds", "swaption") - ): - p.rpush(f"{trade_type}_upload", dumps(trade)) + fund = trade["fund"] + if trade.get("upload", True) and ( + fund in ("SERCGMAST", "BOWDST") or trade_type in ("cds", "swaption") + ): + p.rpush(f"{trade_type}_upload", dumps(trade)) p.delete(trade_type) |