From 744c6b5a97320b0adc596c8d3817b58d325edc2f Mon Sep 17 00:00:00 2001 From: Terry Howe Date: Tue, 27 May 2025 11:44:20 -0600 Subject: [PATCH] fix: kube client create mutex Signed-off-by: Terry Howe --- pkg/kube/client.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/kube/client.go b/pkg/kube/client.go index 9bbd4d9ba..78ed4e088 100644 --- a/pkg/kube/client.go +++ b/pkg/kube/client.go @@ -585,10 +585,14 @@ func batchPerform(infos ResourceList, fn func(*resource.Info) error, errs chan<- } } +var createMutex sync.Mutex + func createResource(info *resource.Info) error { return retry.RetryOnConflict( retry.DefaultRetry, func() error { + createMutex.Lock() + defer createMutex.Unlock() obj, err := resource.NewHelper(info.Client, info.Mapping).WithFieldManager(getManagedFieldsManager()).Create(info.Namespace, true, info.Object) if err != nil { return err