diff options
| author | dvora-h <dvora.heller@redis.com> | 2022-11-08 17:08:30 +0200 |
|---|---|---|
| committer | dvora-h <dvora.heller@redis.com> | 2022-11-08 17:08:30 +0200 |
| commit | c306b37d1dd977cca7905f6680c79203468a1267 (patch) | |
| tree | e1d3f2a18be0fd8091d9fd19a006b7e97784a632 | |
| parent | 9d1d6daa266802ab084b2d773f80401a0afe09a5 (diff) | |
| download | redis-py-cluster-fixes.tar.gz | |
fix review commentscluster-fixes
| -rw-r--r-- | redis/asyncio/cluster.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index 1993015..1ac8e0e 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -306,12 +306,13 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterCommand # Call our on_connect function to configure READONLY mode kwargs["redis_connect_func"] = self.on_connect + self.retry = retry if retry or retry_on_error or connection_error_retry_attempts > 0: # Set a retry object for all cluster nodes self.retry = retry or Retry( default_backoff(), connection_error_retry_attempts ) - if retry_on_error is None: + if not retry_on_error: # Default errors for retrying retry_on_error = [ConnectionError, TimeoutError] self.retry.update_supported_errors(retry_on_error) @@ -338,7 +339,6 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterCommand self.reinitialize_steps = reinitialize_steps self.cluster_error_retry_attempts = cluster_error_retry_attempts self.connection_error_retry_attempts = connection_error_retry_attempts - self.retry = retry self.reinitialize_counter = 0 self.commands_parser = CommandsParser() self.node_flags = self.__class__.NODE_FLAGS.copy() |