Skip to content

Commit aee5c0a

Browse files
committed
try fix for cluster
1 parent 46dff36 commit aee5c0a

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

osscluster.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1712,10 +1712,16 @@ func (c *ClusterClient) txPipelineReadQueued(
17121712

17131713
for _, cmd := range cmds {
17141714
err := statusCmd.readReply(rd)
1715-
if err == nil || c.checkMovedErr(ctx, cmd, err, failedCmds) || isRedisError(err) {
1716-
continue
1715+
if err != nil {
1716+
if c.checkMovedErr(ctx, cmd, err, failedCmds) {
1717+
// will be processed later
1718+
continue
1719+
}
1720+
cmd.SetErr(err)
1721+
if !isRedisError(err) {
1722+
return err
1723+
}
17171724
}
1718-
return err
17191725
}
17201726

17211727
// Parse number of replies.

0 commit comments

Comments
 (0)