remove: nodechecks function as it is not being used

Author: VanillaSpoon

pkg/controller/queuejob/queuejob_controller_ex.go

@@ -922,52 +922,6 @@ func (qjm *XController) chooseAgent(ctx context.Context, qj *arbv1.AppWrapper) s
 	return ""
 }
 
-func (qjm *XController) nodeChecks(histograms map[string]*dto.Metric, aw *arbv1.AppWrapper) bool {
-	ok := true
-	allPods := qjm.GetAggregatedResourcesPerGenericItem(aw)
-
-	// Check only GPUs at this time
-	var podsToCheck []*clusterstateapi.Resource
-
-	for _, pod := range allPods {
-		if pod.GPU > 0 {
-			podsToCheck = append(podsToCheck, pod)
-		}
-	}
-
-	gpuHistogram := histograms["gpu"]
-
-	if gpuHistogram != nil {
-		buckets := gpuHistogram.Histogram.Bucket
-		// Go through pods needing checking
-		for _, gpuPod := range podsToCheck {
-
-			// Go through each bucket of the histogram to find a valid bucket
-			bucketFound := false
-			for _, bucket := range buckets {
-				ub := bucket.UpperBound
-				if ub == nil {
-					klog.Errorf("Unable to get upperbound of histogram bucket.")
-					continue
-				}
-				c := bucket.GetCumulativeCount()
-				var fGPU float64 = float64(gpuPod.GPU)
-				if fGPU < *ub && c > 1 {
-					// Found a valid node
-					bucketFound = true
-					break
-				}
-			}
-			if !bucketFound {
-				ok = false
-				break
-			}
-		}
-	}
-
-	return ok
-}
-
 // Thread to find queue-job(QJ) for next schedule
 func (qjm *XController) ScheduleNext(qj *arbv1.AppWrapper) {
 	ctx := context.Background()