diff --git a/redis/cluster.py b/redis/cluster.py index 6c6cfbf114..db866ce2bf 100644 --- 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