Просмотр исходного кода

Fix missing parameters passing through the _new_redis_client method

Jeremy Llewellyn 9 лет назад
Родитель
Сommit
f23b663d44
1 измененных файлов с 1 добавлено и 1 удалено
  1. 1 1
      celery/backends/redis.py

+ 1 - 1
celery/backends/redis.py

@@ -255,7 +255,7 @@ class RedisBackend(KeyValueStoreBackend):
         return self._new_redis_client(
             socket_timeout=socket_timeout and float(socket_timeout),
             socket_connect_timeout=socket_connect_timeout and float(
-                socket_connect_timeout),
+                socket_connect_timeout), **params
         )
 
     def _new_redis_client(self, **params):