'Returns a Redis connection.'

def get_conn(self):

    if (not self.client):
        self.logger.debug('generating    Redis    client    for    conn_id    "{conn}"    on    {host}:{port}:{db}'.format(conn=self.redis_conn_id, host=self.host, port=self.port, db=self.db))
        try:
            self.client = StrictRedis(host=self.host, port=self.port, password=self.password, db=self.db)
        except Exception as general_error:
            raise AirflowException('Failed    to    create    Redis    client,    error:    {error}'.format(error=str(general_error)))
    return self.client
