fix: add retry condition with kube-apiserver sent GOAWAY (argoproj#17422

) Signed-off-by: penglongli <pelenli@tencent.com> Signed-off-by: Mangaal <angommeeteimangaal@gmail.com>
Mangaal · Mar 14, 2024 · 92ad111 · 92ad111
1 parent 625a7f8
commit 92ad111
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/controller/cache/cache.go b/controller/cache/cache.go
@@ -372,9 +372,14 @@ func isRetryableError(err error) bool {
 		isResourceQuotaConflictErr(err) ||
 		isTransientNetworkErr(err) ||
 		isExceededQuotaErr(err) ||
+		isHTTP2GoawayErr(err) ||
 		errors.Is(err, syscall.ECONNRESET)
 }
 
+func isHTTP2GoawayErr(err error) bool {
+	return strings.Contains(err.Error(), "http2: server sent GOAWAY and closed the connection")
+}
+
 func isExceededQuotaErr(err error) bool {
 	return kerrors.IsForbidden(err) && strings.Contains(err.Error(), "exceeded quota")
 }