Reinitialize the cluster in case of TimeoutError inside a pipeline (#…

…3513)
redis · Feb 17, 2025 · 60f24a9 · 60f24a9
1 parent 746653a
commit 60f24a9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/redis/cluster.py b/redis/cluster.py
@@ -2185,7 +2185,7 @@ def _send_cluster_commands(
                     redis_node = self.get_redis_connection(node)
                     try:
                         connection = get_connection(redis_node, c.args)
-                    except ConnectionError:
+                    except (ConnectionError, TimeoutError):
                         for n in nodes.values():
                             n.connection_pool.release(n.connection)
                         # Connection retries are being handled in the node's