We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b414585 commit df493a8Copy full SHA for df493a8
pkg/controller/node.go
@@ -59,8 +59,13 @@ func (c *Controller) enqueueUpdateNode(oldObj, newObj interface{}) {
59
utilruntime.HandleError(err)
60
return
61
}
62
- klog.V(3).Infof("enqueue update node %s", key)
63
- c.updateNodeQueue.Add(key)
+ if len(newNode.Annotations) == 0 || newNode.Annotations[util.AllocatedAnnotation] != "true" {
+ klog.V(3).Infof("enqueue add node %s", key)
64
+ c.addNodeQueue.Add(key)
65
+ } else {
66
+ klog.V(3).Infof("enqueue update node %s", key)
67
+ c.updateNodeQueue.Add(key)
68
+ }
69
70
71
0 commit comments