set error if queued fails

ndyakov · ndyakov · commit 46dff36ab9e7 · 2025-09-09T15:13:06.000+03:00
diff --git a/redis.go b/redis.go
@@ -703,9 +703,12 @@ func txPipelineReadQueued(rd *proto.Reader, statusCmd *StatusCmd, cmds []Cmder)
 	}
 
 	// Parse +QUEUED.
-	for range cmds {
-		if err := statusCmd.readReply(rd); err != nil && !isRedisError(err) {
-			return err
+	for _, cmd := range cmds {
+		if err := statusCmd.readReply(rd); err != nil {
+			cmd.SetErr(err)
+			if !isRedisError(err) {
+				return err
+			}
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -703,9 +703,12 @@ func txPipelineReadQueued(rd proto.Reader, statusCmd StatusCmd, cmds []Cmder)`
`703`	`703`	`}`
`704`	`704`
`705`	`705`	`// Parse +QUEUED.`
`706`		`- for range cmds {`
`707`		`- if err := statusCmd.readReply(rd); err != nil && !isRedisError(err) {`
`708`		`- return err`
	`706`	`+ for _, cmd := range cmds {`
	`707`	`+ if err := statusCmd.readReply(rd); err != nil {`
	`708`	`+ cmd.SetErr(err)`
	`709`	`+ if !isRedisError(err) {`
	`710`	`+ return err`
	`711`	`+ }`
`709`	`712`	`}`
`710`	`713`	`}`
`711`	`714`