search: fixes

pyrocko · Mar 15, 2024 · 92ed89c · 92ed89c
1 parent c832c32
commit 92ed89c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/qseek/images/images.py b/src/qseek/images/images.py
@@ -112,6 +112,10 @@ async def worker() -> None:
                 "start pre-processing images, queue size %d", self._queue.maxsize
             )
             async for batch in batch_iterator:
+                if batch.is_empty():
+                    logger.debug("empty batch, skipping")
+                    continue
+
                 start_time = datetime_now()
                 images = await self.process_traces(batch.traces)
                 stats.time_per_batch = datetime_now() - start_time