Add valid Exception type to Except in ClusterPipeline (redis#3516)

bssyousefi · petyaslavova · commit dec26ff850cf · 2025-05-13T20:07:42.000+03:00
diff --git a/redis/cluster.py b/redis/cluster.py
@@ -2122,7 +2122,7 @@ def send_cluster_commands(
                     raise_on_error=raise_on_error,
                     allow_redirections=allow_redirections,
                 )
-            except (ClusterDownError, ConnectionError) as e:
+            except RedisCluster.ERRORS_ALLOW_RETRY as e:
                 if retry_attempts > 0:
                     # Try again with the new cluster setup. All other errors
                     # should be raised.

Original file line number	Diff line number	Diff line change
`@@ -2122,7 +2122,7 @@ def send_cluster_commands(`
`2122`	`2122`	`raise_on_error=raise_on_error,`
`2123`	`2123`	`allow_redirections=allow_redirections,`
`2124`	`2124`	`)`
`2125`		`- except (ClusterDownError, ConnectionError) as e:`
	`2125`	`+ except RedisCluster.ERRORS_ALLOW_RETRY as e:`
`2126`	`2126`	`if retry_attempts > 0:`
`2127`	`2127`	`# Try again with the new cluster setup. All other errors`
`2128`	`2128`	`# should be raised.`