def _get_client(self):
        if redis.VERSION < (2, 10, 0):
            raise VersionMismatch(
                'Redis transport requires redis-py versions 2.10.0 or later. '
                'You have {0.__version__}'.format(redis))

        # KombuRedis maintains a connection attribute on it's instance and
        # uses that when executing commands
        # This was added after redis-py was changed.
        class KombuRedis(redis.StrictRedis):  # pragma: no cover

            def __init__(self, *args, **kwargs):
                super(KombuRedis, self).__init__(*args, **kwargs)
                self.connection = self.connection_pool.get_connection('_')

        return KombuRedis
dataset/ETHPy150Open celery/kombu/kombu/transport/redis.py/Channel._get_client/original