Check locked before time expiration

janbjorge · Jan 22, 2025 · 340a2c3 · 340a2c3
1 parent 2014e57
commit 340a2c3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pgqueuer/buffers.py b/pgqueuer/buffers.py
@@ -100,7 +100,7 @@ async def periodic_flush(self) -> None:
         shutdown = asyncio.create_task(self.shutdown.wait())
         pending = set[asyncio.Task]()
         while not self.shutdown.is_set():
-            if helpers.utc_now() > self.next_flush and not self.lock.locked():
+            if not self.lock.locked() and helpers.utc_now() > self.next_flush:
                 self.tm.add(asyncio.create_task(self.flush()))
                 self.next_flush = helpers.utc_now() + helpers.timeout_with_jitter(self.timeout)
 
@@ -134,8 +134,8 @@ async def add(self, item: T) -> None:
 
         if (
             self.events.qsize() >= self.max_size
-            and helpers.utc_now() > self.next_flush
             and not self.lock.locked()
+            and helpers.utc_now() > self.next_flush
         ):
             self.tm.add(asyncio.create_task(self.flush()))
 

diff --git a/uv.lock b/uv.lock