don't brpop if closed

celery · Oct 14, 2024 · 7e0f8b5 · 7e0f8b5
1 parent 47457c1
commit 7e0f8b5
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
@@ -1087,12 +1087,13 @@ def _purge(self, queue):
 
     def close(self):
         self._closing = True
-        if self._in_poll:
-            try:
-                self._brpop_read()
-            except Empty:
-                pass
         if not self.closed:
+            if self._in_poll:
+                try:
+                    self._brpop_read()
+                except Empty:
+                    pass
+
             # remove from channel poller.
             self.connection.cycle.discard(self)