diff --git a/redbeat/schedulers.py b/redbeat/schedulers.py index cbc5ef7..805e639 100644 --- a/redbeat/schedulers.py +++ b/redbeat/schedulers.py @@ -122,6 +122,7 @@ def get_redis(app=None): connection = RedisCluster.from_url(conf.redis_url, **redis_options) elif conf.redis_url.startswith('redis-sentinel') and 'sentinels' in redis_options: from redis.sentinel import Sentinel + connection_kwargs = {} if isinstance(conf.redis_use_ssl, dict): connection_kwargs['ssl'] = True @@ -133,7 +134,7 @@ def get_redis(app=None): db=redis_options.get('db', 0), decode_responses=True, sentinel_kwargs=redis_options.get('sentinel_kwargs'), - **connection_kwargs + **connection_kwargs, ) connection = sentinel.master_for( redis_options.get('service_name', 'master'), db=redis_options.get('db', 0)