From aa42dc8a93b247b54e2c9ee9de81a35bae3bb0ac Mon Sep 17 00:00:00 2001 From: Sarah Hoffmann Date: Thu, 12 Feb 2026 17:18:48 +0100 Subject: [PATCH] fix potential cancelling race with full queue --- src/nominatim_db/db/query_pool.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/nominatim_db/db/query_pool.py b/src/nominatim_db/db/query_pool.py index 2f7307a3..addfb88c 100644 --- a/src/nominatim_db/db/query_pool.py +++ b/src/nominatim_db/db/query_pool.py @@ -38,6 +38,7 @@ class QueryPool: """ Schedule a query for execution. """ if self.is_cancelled: + self.clear_queue() await self.finish() return @@ -47,6 +48,7 @@ class QueryPool: await asyncio.sleep(0) if self.is_cancelled: + self.clear_queue() await self.finish() async def finish(self) -> None: -- 2.39.5