diff --git a/cluster.go b/cluster.go index 6c492cc6..2db73bdb 100644 --- a/cluster.go +++ b/cluster.go @@ -1210,7 +1210,7 @@ func (c *ClusterClient) pipelineReadCmds( continue } - if c.opt.ReadOnly && isLoadingError(err) { + if c.opt.ReadOnly && (isLoadingError(err) || !isRedisError(err)) { node.MarkAsFailing() return err }