def _on_connection_disconnect(self, connection):
        try:
            self.poller.unregister(connection._sock)
        except (AttributeError, __HOLE__):
            pass
dataset/ETHPy150Open celery/kombu/kombu/transport/redis.py/MultiChannelPoller._on_connection_disconnect