updating equivalentWorkload

kubernetes-sigs · Mar 18, 2024 · c828952 · c828952
1 parent 0e2a8af
commit c828952
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/controller/jobframework/reconciler.go b/pkg/controller/jobframework/reconciler.go
@@ -695,8 +695,7 @@ func equivalentToWorkload(ctx context.Context, c client.Client, job GenericJob,
 
 	if runningPodSets := expectedRunningPodSets(ctx, c, wl); runningPodSets != nil {
 		jobPodSetCount := job.PodSets()
-		workloadPodSetCount := wl.Spec.PodSets[1].Count
-		if equality.ComparePodSetSlices(jobPodSets, runningPodSets) || (features.Enabled(features.DynamicallySizedJobs) && job.GVK().Kind == "RayCluster" && jobPodSetCount[1].Count < workloadPodSetCount) {
+		if equality.ComparePodSetSlices(jobPodSets, runningPodSets) || (features.Enabled(features.DynamicallySizedJobs) && job.GVK().Kind == "RayCluster" && jobPodSetCount[1].Count < wl.Spec.PodSets[1].Count) {
 			return true
 		}
 		// If the workload is admitted but the job is suspended, do the check