From 37a9260d5c59f3daf383e7568a4264784f7be80e Mon Sep 17 00:00:00 2001 From: Mengjiao Liu Date: Tue, 4 Apr 2023 18:56:19 +0800 Subject: [PATCH] Migrate pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go to use contextual logging --- .../framework/plugins/defaultpreemption/default_preemption.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go b/pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go index b096f93ed14..a2d20968d11 100644 --- a/pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go +++ b/pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go @@ -142,6 +142,7 @@ func (pl *DefaultPreemption) SelectVictimsOnNode( pod *v1.Pod, nodeInfo *framework.NodeInfo, pdbs []*policy.PodDisruptionBudget) ([]*v1.Pod, int, *framework.Status) { + logger := klog.FromContext(ctx) var potentialVictims []*framework.PodInfo removePod := func(rpi *framework.PodInfo) error { if err := nodeInfo.RemovePod(rpi.Pod); err != nil { @@ -207,7 +208,7 @@ func (pl *DefaultPreemption) SelectVictimsOnNode( } rpi := pi.Pod victims = append(victims, rpi) - klog.V(5).InfoS("Pod is a potential preemption victim on node", "pod", klog.KObj(rpi), "node", klog.KObj(nodeInfo.Node())) + logger.V(5).Info("Pod is a potential preemption victim on node", "pod", klog.KObj(rpi), "node", klog.KObj(nodeInfo.Node())) } return fits, nil }