Update internal/net/grpc/status/status.go

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> Signed-off-by: Yusuke Kato <[email protected]>
vdaas · Sep 21, 2024 · 3847fe2 · 3847fe2
1 parent 25c6bd6
commit 3847fe2
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/internal/net/grpc/status/status.go b/internal/net/grpc/status/status.go
@@ -684,10 +684,7 @@ func withDetails(st *Status, err error, details ...any) *Status {
 			for _, msg := range ds {
 				r, ok := msg.(*errdetails.RetryInfo)
 				if ok && r != nil {
-					if m.GetRetryDelay().GetSeconds() == 0 &&
-						r.GetRetryDelay().GetSeconds() != 0 {
-						m.RetryDelay = r.GetRetryDelay()
-					} else if m.GetRetryDelay().GetSeconds() > r.GetRetryDelay().GetSeconds() {
+					if m.GetRetryDelay() == nil || r.GetRetryDelay().Seconds < m.GetRetryDelay().Seconds {
 						m.RetryDelay = r.GetRetryDelay()
 					}
 				}