kubernetes
/
autoscaler
mirror of https://github.com/kubernetes/autoscaler.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Better error checking in GetDaemonSetPodsForNode

This commit is contained in:
Łukasz Osipiuk 2020-02-04 14:40:15 +01:00
parent 0dca11fa11
commit e8eb30e75a
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cluster-autoscaler/utils/daemonset/daemonset.go
View File

@ -42,8 +42,14 @@ func GetDaemonSetPodsForNode(nodeInfo *schedulernodeinfo.NodeInfo, daemonsets []
for _, ds := range daemonsets { for _, ds := range daemonsets {
pod := newPod(ds, nodeInfo.Node().Name) pod := newPod(ds, nodeInfo.Node().Name)
if err := predicateChecker.CheckPredicates(clusterSnapshot, pod, simulator.FakeNodeInfoForNodeName(nodeInfo.Node().Name)); err == nil { err := predicateChecker.CheckPredicates(clusterSnapshot, pod, simulator.FakeNodeInfoForNodeName(nodeInfo.Node().Name))
if err == nil {
result = append(result, pod) result = append(result, pod)
} else if err.ErrorType() == simulator.NotSchedulablePredicateError {
// ok; we are just skipping this daemonset
} else {
// unexpected error
return nil, fmt.Errorf("unexpected error while calling PredicateChecker; %v", err)
} }
} }
return result, nil return result, nil