rm code

celery · Oct 21, 2024 · 5dbfb47 · 5dbfb47
1 parent b6eea5f
commit 5dbfb47
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
@@ -1087,11 +1087,6 @@ 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:
             # remove from channel poller.
             self.connection.cycle.discard(self)