fix: mixed retry

YangruiEmma · Aug 27, 2024 · ba33680 · ba33680
1 parent 1db1bb7
commit ba33680
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/retry/mixed_retryer.go b/pkg/retry/mixed_retryer.go
@@ -177,12 +177,15 @@ func (r *mixedRetryer) Do(ctx context.Context, rpcCall RPCCallFunc, firstRI rpci
 					continue
 				}
 				if callCount < retryTimes+1 {
-					if _, ok := r.ShouldRetry(ctx, nil, callCount, req, cbKey); ok {
+					if msg, ok := r.ShouldRetry(ctx, nil, callCount, req, cbKey); ok {
 						if r.isRetryResult(ctx, res.ri, res.resp, res.err, &r.policy.FailurePolicy) {
 							doCall = true
 							timer.Reset(retryDelay)
 							continue
 						}
+					} else if msg != "" {
+						appendMsg := fmt.Sprintf("retried %d, %s", callCount-1, msg)
+						appendErrMsg(res.err, appendMsg)
 					}
 				} else if r.isRetryResult(ctx, res.ri, res.resp, res.err, &r.policy.FailurePolicy) {
 					continue