reduce status update freq (#276)

Author: asm582

CONTROLLER_VERSION

@@ -1 +1 @@
-1.29.51
+1.29.52

pkg/controller/queuejob/queuejob_controller_ex.go

@@ -438,9 +438,15 @@ func (qjm *XController) PreemptQueueJobs() {
 		cleanAppWrapper := false
 
 		if (aw.Status.Running + aw.Status.Succeeded) < int32(aw.Spec.SchedSpec.MinAvailable) {
-			message = fmt.Sprintf("Insufficient number of Running and Completed pods, minimum=%d, running=%d, completed=%d.", aw.Spec.SchedSpec.MinAvailable, aw.Status.Running, aw.Status.Succeeded)
-			cond := GenerateAppWrapperCondition(arbv1.AppWrapperCondPreemptCandidate, v1.ConditionTrue, "MinPodsNotRunning", message)
-			newjob.Status.Conditions = append(newjob.Status.Conditions, cond)
+			index := getIndexOfMatchedCondition(aw, arbv1.AppWrapperCondPreemptCandidate, "MinPodsNotRunning")
+			if index < 0 {
+				message = fmt.Sprintf("Insufficient number of Running and Completed pods, minimum=%d, running=%d, completed=%d.", aw.Spec.SchedSpec.MinAvailable, aw.Status.Running, aw.Status.Succeeded)
+				cond := GenerateAppWrapperCondition(arbv1.AppWrapperCondPreemptCandidate, v1.ConditionTrue, "MinPodsNotRunning", message)
+				newjob.Status.Conditions = append(newjob.Status.Conditions, cond)
+			} else {
+				cond := GenerateAppWrapperCondition(arbv1.AppWrapperCondPreemptCandidate, v1.ConditionTrue, "MinPodsNotRunning", "")
+				newjob.Status.Conditions[index] = *cond.DeepCopy()
+			}
 
 			if aw.Spec.SchedSpec.Requeuing.GrowthType == "exponential" {
 				newjob.Spec.SchedSpec.Requeuing.TimeInSeconds += aw.Spec.SchedSpec.Requeuing.TimeInSeconds