summaryrefslogtreecommitdiff
path: root/redis/cluster.py
diff options
context:
space:
mode:
Diffstat (limited to 'redis/cluster.py')
-rw-r--r--redis/cluster.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/redis/cluster.py b/redis/cluster.py
index f115007..235d8f2 100644
--- a/redis/cluster.py
+++ b/redis/cluster.py
@@ -1437,6 +1437,8 @@ class NodesManager:
if target_node is None or target_node.redis_connection is None:
# create new cluster node for this cluster
target_node = ClusterNode(host, port, role)
+ if target_node.server_type != role:
+ target_node.server_type = role
return target_node