Test

Author: mbobrovskyi

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: time.Nanosecond},
+				RecoveryTimeout: &metav1.Duration{Duration: util.Timeout},
 				RequeuingStrategy: &configapi.RequeuingStrategy{
 					Timestamp:          ptr.To(configapi.EvictionTimestamp),
 					BackoffBaseSeconds: ptr.To(int32(1)),