Don't connect to failed replica nodes

jgaskins · May 6, 2023 · 5345df3 · 5345df3
1 parent 2e15ca5
commit 5345df3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/cluster.cr b/src/cluster.cr
@@ -143,7 +143,9 @@ module Redis
       end
 
       @read_nodes.each_value do |node|
-        node.replica_of = @write_nodes[replica_map[node.id]]
+        unless node.flags.fail?
+          node.replica_of = @write_nodes[replica_map[node.id]]
+        end
       end
 
       @write_pools = @write_nodes.map do |_id, node|