Close empty queues in init_prios().

2026-06-20 01:40:06 +05:00 · 2026-06-20 01:40:06 +05:00 · 55b457f11d
parent 22be98c3af
commit 55b457f11d
1 changed files with 4 additions and 0 deletions
--- a/scrapy/pqueues.py
+++ b/scrapy/pqueues.py
@ -141,10 +141,14 @@ class ScrapyPriorityQueue:
            q = self.qfactory(priority)
            if q:
                self.queues[priority] = q
+            else:
+                q.close()
            if self._start_queue_cls:
                q = self._sqfactory(priority)
                if q:
                    self._start_queues[priority] = q
+                else:
+                    q.close()

        self.curprio = min(startprios)