fix filter NotReady node

volcano-sh · Nov 7, 2019 · b9741c1 · b9741c1
1 parent 124d6aa
commit b9741c1
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/pkg/scheduler/api/node_info.go b/pkg/scheduler/api/node_info.go
@@ -126,6 +126,17 @@ func (ni *NodeInfo) setNodeState(node *v1.Node) {
 		return
 	}
 
+	// If node not ready, e.g. power off
+	for _, cond := range node.Status.Conditions {
+		if cond.Type == v1.NodeReady && cond.Status != v1.ConditionTrue {
+			ni.State = NodeState{
+				Phase:  NotReady,
+				Reason: "NotReady",
+			}
+			return
+		}
+	}
+
 	// Node is ready (ignore node conditions because of taint/toleration)
 	ni.State = NodeState{
 		Phase:  Ready,