Commit f12f7c51 authored by Abhishek Gupta's avatar Abhishek Gupta

Modifying scheduler integration test for unschedulable nodes

parent bc9c4614
...@@ -170,8 +170,11 @@ func DoTestUnschedulableNodes(t *testing.T, restClient *client.Client, nodeStore ...@@ -170,8 +170,11 @@ func DoTestUnschedulableNodes(t *testing.T, restClient *client.Client, nodeStore
t.Fatalf("Failed to update node with unschedulable=true: %v", err) t.Fatalf("Failed to update node with unschedulable=true: %v", err)
} }
err = waitForReflection(t, s, nodeKey, func(node interface{}) bool { err = waitForReflection(t, s, nodeKey, func(node interface{}) bool {
// An unschedulable node should get deleted from the store // An unschedulable node should still be present in the store
return node == nil // Nodes that are unschedulable or that are not ready or
// have their disk full (Node.Spec.Conditions) are exluded
// based on NodeConditionPredicate, a separate check
return node != nil && node.(*api.Node).Spec.Unschedulable == true
}) })
if err != nil { if err != nil {
t.Fatalf("Failed to observe reflected update for setting unschedulable=true: %v", err) t.Fatalf("Failed to observe reflected update for setting unschedulable=true: %v", err)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment