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