Revert back to StrictRedis client

This commit is contained in:
amercader 2019-08-26 12:26:05 +02:00
parent 8b2f2f9a24
commit 51bf79a626
1 changed files with 2 additions and 2 deletions

View File

@ -67,9 +67,9 @@ def get_connection_amqp():
def get_connection_redis():
if not config.get('ckan.harvest.mq.hostname') and config.get('ckan.redis.url'):
return redis.Redis.from_url(config['ckan.redis.url'])
return redis.StrictRedis.from_url(config['ckan.redis.url'])
else:
return redis.Redis(host=config.get('ckan.harvest.mq.hostname', HOSTNAME),
return redis.StrictRedis(host=config.get('ckan.harvest.mq.hostname', HOSTNAME),
port=int(config.get('ckan.harvest.mq.port', REDIS_PORT)),
password=config.get('ckan.harvest.mq.password', None),
db=int(config.get('ckan.harvest.mq.redis_db', REDIS_DB)))