github/kamaji
1
0
Fork 0
mirror of https://github.com/clastix/kamaji.git synced 2026-08-26 00:47:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: retry scale on conflict (#778)

Browse Source 
Signed-off-by: Dario Tranchitella <dario@tranchitella.eu>
This commit is contained in:
Dario Tranchitella
2025-04-08 20:46:30 +02:00
committed by GitHub
parent 3e79845175
commit f87a057809
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
e2e/utils_test.go
+8 -3
View File
@@ -17,6 +17,7 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/util/retry"
"sigs.k8s.io/controller-runtime/pkg/client"
kamajiv1alpha1 "github.com/clastix/kamaji/api/v1alpha1"
@@ -199,7 +200,11 @@ func PodsServiceAccountMustEqualTo(tcp *kamajiv1alpha1.TenantControlPlane, sa *c
func ScaleTenantControlPlane(tcp *kamajiv1alpha1.TenantControlPlane, replicas int32) {
GinkgoHelper()
Expect(k8sClient.Get(context.Background(), client.ObjectKeyFromObject(tcp), tcp)).To(Succeed())
tcp.Spec.ControlPlane.Deployment.Replicas = &replicas
Expect(k8sClient.Update(context.Background(), tcp)).To(Succeed())
err := retry.RetryOnConflict(retry.DefaultRetry, func() error {
Expect(k8sClient.Get(context.Background(), client.ObjectKeyFromObject(tcp), tcp)).To(Succeed())
tcp.Spec.ControlPlane.Deployment.Replicas = &replicas
return k8sClient.Update(context.Background(), tcp)
})
Expect(err).To(Succeed())
}