和descheduler 联动进行安全重调取

Signed-off-by: gj199575 <409237405@qq.com>
volcano-sh · Jul 14, 2023 · 33360c5 · 33360c5
1 parent 5302995
commit 33360c5
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/scheduler/cache/cache.go b/pkg/scheduler/cache/cache.go
@@ -161,7 +161,12 @@ func (db *DefaultBinder) Bind(kubeClient kubernetes.Interface, tasks []*scheduli
 	var errTasks []*schedulingapi.TaskInfo
 	for _, task := range tasks {
 		p := task.Pod
-		if err := kubeClient.CoreV1().Pods(p.Namespace).Bind(context.TODO(),
+		if p.Annotations["is-fake"] == "true" {
+			p.Annotations["fake-pod"] = task.NodeName
+			p.Spec.NodeName = ""
+			update, err := kubeClient.CoreV1().Pods(p.Namespace).Update(context.TODO(), p, metav1.UpdateOptions{})
+			klog.Info(update, err)
+		} else if err := kubeClient.CoreV1().Pods(p.Namespace).Bind(context.TODO(),
 			&v1.Binding{
 				ObjectMeta: metav1.ObjectMeta{Namespace: p.Namespace, Name: p.Name, UID: p.UID, Annotations: p.Annotations},
 				Target: v1.ObjectReference{