From 15c24a3351845c1f67a95116a31ae8165d24ca51 Mon Sep 17 00:00:00 2001 From: Daniel Vega-Myhre Date: Tue, 13 Feb 2024 06:57:12 +0000 Subject: [PATCH] add leader pot not scheduled info log --- pkg/webhooks/pod_admission_webhook.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/webhooks/pod_admission_webhook.go b/pkg/webhooks/pod_admission_webhook.go index 96465f1b..ad9149c5 100644 --- a/pkg/webhooks/pod_admission_webhook.go +++ b/pkg/webhooks/pod_admission_webhook.go @@ -75,11 +75,16 @@ func (p *podWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (ad } func (p *podWebhook) leaderPodScheduled(ctx context.Context, pod *corev1.Pod) (bool, error) { + log := ctrl.LoggerFrom(ctx) leaderPod, err := p.leaderPodForFollower(ctx, pod) if err != nil { return false, err } - return leaderPod.Spec.NodeName != "", nil + scheduled := leaderPod.Spec.NodeName != "" + if !scheduled { + log.V(3).Info("leader pod %s is not yet scheduled", leaderPod.Name) + } + return scheduled, nil } func (p *podWebhook) leaderPodForFollower(ctx context.Context, pod *corev1.Pod) (*corev1.Pod, error) {