diff --git a/redis.go b/redis.go index b20b34b9..7fbb7fd3 100644 --- a/redis.go +++ b/redis.go @@ -205,7 +205,7 @@ func pipelineReadCmds(cn *pool.Conn, cmds []Cmder) (retry bool, firstErr error) firstErr = err } } - return false, firstErr + return } func (c *baseClient) txPipelineProcessCmds(cn *pool.Conn, cmds []Cmder) (bool, error) {