diff options
| -rw-r--r-- | python/strat_cash_realloc.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/strat_cash_realloc.py b/python/strat_cash_realloc.py index aa97b243..f8889f54 100644 --- a/python/strat_cash_realloc.py +++ b/python/strat_cash_realloc.py @@ -15,7 +15,7 @@ def generate_csv(date, fund="BOWDST"): fund, ), ) - if value := c.fetchone(): + if c.fetchone(): return c.execute( "SELECT * FROM list_orphaned_cash(%s, %s) ", @@ -32,6 +32,8 @@ def generate_csv(date, fund="BOWDST"): ) obj.stage() offset.stage() + if not WireDeal._insert_queue: + return for wire in WireDeal.commit(returning=True): Bowdst.staging_queue.append(wire.to_globeop("NEW")) buf, dest = Bowdst.build_buffer("wire") |