Skip to content

Commit 60f24a9

Browse files
authored
Reinitialize the cluster in case of TimeoutError inside a pipeline (#3513)
1 parent 746653a commit 60f24a9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

redis/cluster.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2185,7 +2185,7 @@ def _send_cluster_commands(
21852185
redis_node = self.get_redis_connection(node)
21862186
try:
21872187
connection = get_connection(redis_node, c.args)
2188-
except ConnectionError:
2188+
except (ConnectionError, TimeoutError):
21892189
for n in nodes.values():
21902190
n.connection_pool.release(n.connection)
21912191
# Connection retries are being handled in the node's

0 commit comments

Comments
 (0)