diff --git a/lib/redis_client/cluster/node/base_topology.rb b/lib/redis_client/cluster/node/base_topology.rb index 82c5f2c..bc69292 100644 --- a/lib/redis_client/cluster/node/base_topology.rb +++ b/lib/redis_client/cluster/node/base_topology.rb @@ -54,7 +54,7 @@ def disconnect_from_unwanted_nodes(options) def connect_to_new_nodes(options) (options.keys - @clients.keys).each do |node_key| option = options[node_key].merge(@client_options) - config = ::RedisClient::Cluster::Node::Config.new(scale_read: !@primary_node_keys.include?(node_key), **option) + config = ::RedisClient::Cluster::Node::Config.new(scale_read: @replica_node_keys.include?(node_key), **option) client = @pool.nil? ? config.new_client : config.new_pool(**@pool) @clients[node_key] = client end