Fix lag of 1 in offset commits caused by StreamTarget (#505)

mlrun · Feb 28, 2024 · 7f9ec9d · 7f9ec9d
1 parent 33bf028
commit 7f9ec9d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/storey/targets.py b/storey/targets.py
@@ -893,6 +893,7 @@ async def _worker(self):
                 in_flight_reqs.append(None)
                 in_flight_events.append(None)
             while True:
+                event = None
                 try:
                     request_sent_on_empty_queue = False
                     if self._q.empty():