Add valid Exception type to Except in ClusterPipeline

bssyousefi · web-flow · commit a11d4bbfad64 · 2025-02-19T07:56:26.000-05:00
diff --git a/redis/cluster.py b/redis/cluster.py
@@ -2120,7 +2120,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
`@@ -2120,7 +2120,7 @@ def send_cluster_commands(`
`2120`	`2120`	`raise_on_error=raise_on_error,`
`2121`	`2121`	`allow_redirections=allow_redirections,`
`2122`	`2122`	`)`
`2123`		`- except (ClusterDownError, ConnectionError) as e:`
	`2123`	`+ except RedisCluster.ERRORS_ALLOW_RETRY as e:`
`2124`	`2124`	`if retry_attempts > 0:`
`2125`	`2125`	`# Try again with the new cluster setup. All other errors`
`2126`	`2126`	`# should be raised.`