From 994795ca28ced9c144c29b21cee8a75b0e3805d4 Mon Sep 17 00:00:00 2001 From: Arnob Kumar Saha Date: Thu, 22 Feb 2024 15:32:30 +0600 Subject: [PATCH] Set different retry periods for CRDs (#579) Signed-off-by: Arnob kumar saha --- apiextensions/v1/crd.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/apiextensions/v1/crd.go b/apiextensions/v1/crd.go index d49713a2c..28156ee2a 100644 --- a/apiextensions/v1/crd.go +++ b/apiextensions/v1/crd.go @@ -18,6 +18,7 @@ package v1 import ( "context" + "time" "github.com/pkg/errors" api "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" @@ -29,6 +30,10 @@ import ( kutil "kmodules.xyz/client-go" ) +const ( + RetryTimeout = 10 * time.Minute +) + func CreateOrUpdateCustomResourceDefinition( ctx context.Context, c cs.Interface, @@ -70,7 +75,7 @@ func TryUpdateCustomResourceDefinition( opts metav1.UpdateOptions, ) (result *api.CustomResourceDefinition, err error) { attempt := 0 - err = wait.PollUntilContextTimeout(ctx, kutil.RetryInterval, kutil.RetryTimeout, true, func(ctx context.Context) (bool, error) { + err = wait.PollUntilContextTimeout(ctx, kutil.RetryInterval, RetryTimeout, true, func(ctx context.Context) (bool, error) { attempt++ cur, e2 := c.ApiextensionsV1().CustomResourceDefinitions().Get(ctx, name, metav1.GetOptions{}) if kerr.IsNotFound(e2) {