From beacf60b38b1cfd4128dbd82b8f26746e78a4fe5 Mon Sep 17 00:00:00 2001 From: Jeff Yang Date: Mon, 15 Mar 2021 21:34:57 -0700 Subject: [PATCH 1/2] add ssl_cert_reqs to redis options --- django_rq/queues.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/django_rq/queues.py b/django_rq/queues.py index 7f08cb28..74a334dc 100644 --- a/django_rq/queues.py +++ b/django_rq/queues.py @@ -112,7 +112,7 @@ def get_redis_connection(config, use_strict_redis=False): service_name=config['MASTER_NAME'], redis_class=redis_cls, ) - return redis_cls(host=config['HOST'], port=config['PORT'], db=config['DB'], password=config.get('PASSWORD'), ssl=config.get('SSL', False)) + return redis_cls(host=config['HOST'], port=config['PORT'], db=config['DB'], password=config.get('PASSWORD'), ssl=config.get('SSL', False), ssl_cert_reqs=config.get('SSL_CERT_REQS', 'required')) def get_connection(name='default', use_strict_redis=False): From a8f0bf1d1e726cd0b18e0a0b7c4e3bb8b57f43ce Mon Sep 17 00:00:00 2001 From: Jeff Yang Date: Mon, 15 Mar 2021 21:59:33 -0700 Subject: [PATCH 2/2] add username to redis options and default db to 0 --- django_rq/queues.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/django_rq/queues.py b/django_rq/queues.py index 74a334dc..0645794c 100644 --- a/django_rq/queues.py +++ b/django_rq/queues.py @@ -112,7 +112,7 @@ def get_redis_connection(config, use_strict_redis=False): service_name=config['MASTER_NAME'], redis_class=redis_cls, ) - return redis_cls(host=config['HOST'], port=config['PORT'], db=config['DB'], password=config.get('PASSWORD'), ssl=config.get('SSL', False), ssl_cert_reqs=config.get('SSL_CERT_REQS', 'required')) + return redis_cls(host=config['HOST'], port=config['PORT'], db=config.get('DB', 0), username=config.get('USERNAME', None), password=config.get('PASSWORD'), ssl=config.get('SSL', False), ssl_cert_reqs=config.get('SSL_CERT_REQS', 'required')) def get_connection(name='default', use_strict_redis=False):