Fix recieve socket_keepalive_options

celery · Jun 5, 2023 · 667278c · 667278c
1 parent 8d0b6f7
commit 667278c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/celery/backends/redis.py b/celery/backends/redis.py
@@ -228,7 +228,7 @@ def __init__(self, host=None, port=None, db=None, password=None,
         socket_connect_timeout = _get('redis_socket_connect_timeout')
         retry_on_timeout = _get('redis_retry_on_timeout')
         socket_keepalive = _get('redis_socket_keepalive')
-        socket_keepalive_options = self._transport_options['socket_keepalive_options']
+        socket_keepalive_options = self._transport_options.get('socket_keepalive_options', {})
         health_check_interval = _get('redis_backend_health_check_interval')
 
         self.connparams = {