diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index bf9e9f49..585b70df 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -206,7 +206,7 @@ class MultiChannelPoller(object): for fd in self._chan_to_sock.itervalues(): try: self.poller.unregister(fd) - except KeyError: + except (KeyError, ValueError): pass self._channels.clear() self._fd_to_chan.clear()