diff --git a/pkg/controller/nodelifecycle/node_lifecycle_controller.go b/pkg/controller/nodelifecycle/node_lifecycle_controller.go index d5154f003e7..598b37c1cb3 100644 --- a/pkg/controller/nodelifecycle/node_lifecycle_controller.go +++ b/pkg/controller/nodelifecycle/node_lifecycle_controller.go @@ -288,7 +288,7 @@ func NewNodeLifecycleController( runTaintManager: runTaintManager, useTaintBasedEvictions: useTaintBasedEvictions && runTaintManager, taintNodeByCondition: taintNodeByCondition, - nodeUpdateQueue: workqueue.New(), + nodeUpdateQueue: workqueue.NewNamed("node_lifecycle_controller"), } if useTaintBasedEvictions { klog.Infof("Controller is using taint based evictions.") diff --git a/pkg/controller/nodelifecycle/scheduler/taint_manager.go b/pkg/controller/nodelifecycle/scheduler/taint_manager.go index fbf683077f1..6d32bedfad8 100644 --- a/pkg/controller/nodelifecycle/scheduler/taint_manager.go +++ b/pkg/controller/nodelifecycle/scheduler/taint_manager.go @@ -185,8 +185,8 @@ func NewNoExecuteTaintManager(c clientset.Interface, getPod GetPodFunc, getNode getNode: getNode, taintedNodes: make(map[string][]v1.Taint), - nodeUpdateQueue: workqueue.New(), - podUpdateQueue: workqueue.New(), + nodeUpdateQueue: workqueue.NewNamed("noexec_taint_node"), + podUpdateQueue: workqueue.NewNamed("noexec_taint_pod"), } tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent))