fixed lint

kubernetes-sigs · Mar 18, 2024 · d9bdcd9 · d9bdcd9
1 parent c828952
commit d9bdcd9
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/test/integration/controller/jobs/raycluster/raycluster_controller_test.go b/test/integration/controller/jobs/raycluster/raycluster_controller_test.go
@@ -634,7 +634,13 @@ var _ = ginkgo.Describe("RayCluster Job controller interacting with scheduler",
 		util.ExpectReservingActiveWorkloadsMetric(clusterQueue, 1)
 	})
 
-	features.SetEnable(features.DynamicallySizedJobs, true)
+	gomega.Eventually(func() bool {
+		if err := features.SetEnable(features.DynamicallySizedJobs, true); err != nil {
+			return false
+		}
+		return features.Enabled(features.DynamicallySizedJobs)
+	}, util.Timeout, util.Interval).Should(gomega.BeTrue())
+
 	ginkgo.It("Should not suspend job when there's a scale down", func() {
 		ginkgo.By("creating localQueue")
 		localQueue = testing.MakeLocalQueue("local-queue", ns.Name).ClusterQueue(clusterQueue.Name).Obj()