We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 96c0b45 commit 53c5cc0Copy full SHA for 53c5cc0
reflex/istate/manager/disk.py
@@ -209,9 +209,12 @@ async def _process_write_queue_delay(self):
209
if self._write_queue:
210
# There are still items in the queue, schedule another run.
211
now = time.time()
212
- next_write_in = min(
213
- self._write_debounce_seconds - (now - item.timestamp)
214
- for item in self._write_queue.values()
+ next_write_in = max(
+ 0,
+ min(
215
+ self._write_debounce_seconds - (now - item.timestamp)
216
+ for item in self._write_queue.values()
217
+ ),
218
)
219
await asyncio.sleep(next_write_in)
220
elif self._write_debounce_seconds > 0:
0 commit comments