DevOps/truecharts
2
0
Fork 0
Code Issues Pull Requests Actions 29 Packages Projects Releases 1 Wiki Activity

fix(clustertool): retry kubectl apply after error with 15s wait

Browse Source
This commit is contained in:
Kjeld Schouten
2024-11-09 21:04:48 +01:00
parent 01a64b1534
commit a62135cdd9
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
clustertool/pkg/kubectlcmds/apply.go
+7 -2
View File
@@ -7,6 +7,7 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"path/filepath" "path/filepath"
"time"
"github.com/rs/zerolog/log" "github.com/rs/zerolog/log"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
@@ -64,8 +65,12 @@ func applyYAML(k8sClient client.Client, yamlData []byte) error {
return fmt.Errorf("failed to unmarshal node: %v", err) return fmt.Errorf("failed to unmarshal node: %v", err)
} }
if err := k8sClient.Patch(context.TODO(), obj, client.Apply, client.FieldOwner("kustomize-controller")); err != nil { if err := k8sClient.Patch(context.TODO(), obj, client.Apply, client.FieldOwner("kustomize-controller")); err != nil {
log.Error().Err(err).Msg("Failed to apply object") log.Warn().Err(err).Msg("Failed to apply yaml object... trying again in 15 seconds...")
return fmt.Errorf("failed to apply object: %v", err) time.Sleep(15 * time.Second)
if err := k8sClient.Patch(context.TODO(), obj, client.Apply, client.FieldOwner("kustomize-controller")); err != nil {
log.Error().Err(err).Msg("Failed to apply object")
return fmt.Errorf("failed to apply object: %v", err)
}
} }
log.Info().Msgf("Successfully applied object: %s of kind: %s in namespace: %s", obj.GetName(), obj.GetKind(), obj.GetNamespace()) log.Info().Msgf("Successfully applied object: %s of kind: %s in namespace: %s", obj.GetName(), obj.GetKind(), obj.GetNamespace())
} }