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