We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ad25181 commit 2e999ccCopy full SHA for 2e999cc
backend/deepchecks_monitoring/resources.py
@@ -294,7 +294,10 @@ def redis_client(self) -> t.Optional[Redis]:
294
if self._redis_client is None and self.redis_settings.redis_uri:
295
settings = create_settings_dict(self.redis_settings)
296
try:
297
- self._redis_client = RedisCluster.from_url(cluster_error_retry_attempts=2, **settings)
+ self._redis_client = RedisCluster.from_url(
298
+ cluster_error_retry_attempts=self.redis_settings.cluster_error_retry_attempts,
299
+ **settings
300
+ )
301
except redis_exceptions.RedisClusterException:
302
self._redis_client = Redis.from_url(**settings)
303
0 commit comments