Test test-e2e-customconfigs

Author: mbobrovskyi

Makefile-test.mk

@@ -204,7 +204,8 @@ run-test-e2e-customconfigs-%: K8S_VERSION = $(@:run-test-e2e-customconfigs-%=%)
 run-test-e2e-customconfigs-%:
 	@echo Running customconfigs e2e for k8s ${K8S_VERSION}
 	E2E_KIND_VERSION="kindest/node:v$(K8S_VERSION)" KIND_CLUSTER_NAME=$(KIND_CLUSTER_NAME) CREATE_KIND_CLUSTER=$(CREATE_KIND_CLUSTER) \
-		ARTIFACTS="$(ARTIFACTS)/$@" IMAGE_TAG=$(IMAGE_TAG) GINKGO_ARGS="$(GINKGO_ARGS)" \
+		ARTIFACTS="$(ARTIFACTS)/$@" IMAGE_TAG=$(IMAGE_TAG) \
+		GINKGO_ARGS="--repeat=50" \
 		KIND_CLUSTER_FILE="kind-cluster.yaml" E2E_TARGET_FOLDER="customconfigs" \
 		JOBSET_VERSION=$(JOBSET_VERSION) APPWRAPPER_VERSION=$(APPWRAPPER_VERSION) \
 		LEADERWORKERSET_VERSION=$(LEADERWORKERSET_VERSION) \

pkg/workload/workload.go

@@ -1030,12 +1030,14 @@ func mergePatchStatus(ctx context.Context, c client.Client, wl *kueue.Workload,
 		patchOptions = append(patchOptions, clientutil.WithRetryOnConflict())
 	}
 	return clientutil.PatchStatus(ctx, c, wl, func() (bool, error) {
+		time.Sleep(time.Second)
 		return update(wl)
 	}, patchOptions...)
 }
 
 func applyPatchStatus(ctx context.Context, c client.Client, wl *kueue.Workload, owner client.FieldOwner, update UpdateFunc) error {
 	if updated, err := update(wl); err != nil || !updated {
+		time.Sleep(time.Second)
 		return err
 	}
 	return c.Status().Patch(ctx, wl, client.Apply, owner, client.ForceOwnership)

test/e2e/customconfigs/waitforpodsready_test.go

@@ -132,7 +132,7 @@ var _ = ginkgo.Describe("WaitForPodsReady with tiny Timeout and no RecoveryTimeo
 		util.ExpectObjectToBeDeleted(ctx, k8sClient, metricsReaderClusterRoleBinding, true)
 	})
 
-	ginkgo.It("should evict and requeue workload when pods readiness timeout is surpassed", func() {
+	ginkgo.FIt("should evict and requeue workload when pods readiness timeout is surpassed", func() {
 		ginkgo.By("creating a suspended job so its pods never report Ready", func() {
 			job = testingjob.MakeJob("job-timeout", ns.Name).
 				Queue(kueue.LocalQueueName(lq.Name)).
@@ -238,7 +238,7 @@ var _ = ginkgo.Describe("WaitForPodsReady with default Timeout and a tiny Recove
 			cfg.WaitForPodsReady = &configapi.WaitForPodsReady{
 				Timeout:         metav1.Duration{Duration: 5 * time.Minute},
 				BlockAdmission:  ptr.To(true),
-				RecoveryTimeout: &metav1.Duration{Duration: util.TinyTimeout},
+				RecoveryTimeout: &metav1.Duration{Duration: time.Nanosecond},
 				RequeuingStrategy: &configapi.RequeuingStrategy{
 					Timestamp:          ptr.To(configapi.EvictionTimestamp),
 					BackoffBaseSeconds: ptr.To(int32(1)),
@@ -288,7 +288,7 @@ var _ = ginkgo.Describe("WaitForPodsReady with default Timeout and a tiny Recove
 		util.ExpectObjectToBeDeleted(ctx, k8sClient, metricsReaderClusterRoleBinding, true)
 	})
 
-	ginkgo.It("should evict and requeue workload when pod failure causes recovery timeout", func() {
+	ginkgo.FIt("should evict and requeue workload when pod failure causes recovery timeout", func() {
 		ginkgo.By("creating a job", func() {
 			job = testingjob.MakeJob("job-recovery-timeout", ns.Name).
 				Image(util.GetAgnHostImage(), util.BehaviorWaitForDeletion).