diff --git a/osscluster.go b/osscluster.go index 1e9ee7de4..d4b8c6b56 100644 --- a/osscluster.go +++ b/osscluster.go @@ -1408,7 +1408,7 @@ func (c *ClusterClient) pipelineReadCmds( continue } - if c.opt.ReadOnly && isBadConn(err, false, node.Client.getAddr()) { + if c.opt.ReadOnly { node.MarkAsFailing() }