From f786c8c0bc869bfb6af81b703014f385fb5ac52e Mon Sep 17 00:00:00 2001 From: Tasos Maschalidis Date: Tue, 17 Dec 2024 18:53:30 +0200 Subject: [PATCH] Fix k3s run:detached not returning pod name in a similar fashion to docker-local (as described in docs) --- plugins/scheduler-k3s/triggers.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/plugins/scheduler-k3s/triggers.go b/plugins/scheduler-k3s/triggers.go index 2b5bb67c3..141242f89 100644 --- a/plugins/scheduler-k3s/triggers.go +++ b/plugins/scheduler-k3s/triggers.go @@ -1192,7 +1192,7 @@ func TriggerSchedulerRun(scheduler string, appName string, envCount int, args [] } batchJobSelector := fmt.Sprintf("batch.kubernetes.io/job-name=%s", createdJob.Name) - _, err = waitForPodToExist(ctx, WaitForPodToExistInput{ + pods, err := waitForPodToExist(ctx, WaitForPodToExistInput{ Clientset: clientset, Namespace: namespace, RetryCount: 3, @@ -1202,6 +1202,7 @@ func TriggerSchedulerRun(scheduler string, appName string, envCount int, args [] return fmt.Errorf("Error waiting for pod to exist: %w", err) } if !attachToPod { + fmt.Println(pods[0].Name) return nil } @@ -1254,7 +1255,7 @@ func TriggerSchedulerRun(scheduler string, appName string, envCount int, args [] return fmt.Errorf("Error waiting for pod to be running: %w", err) } - pods, err := clientset.ListPods(ctx, ListPodsInput{ + pods, err = clientset.ListPods(ctx, ListPodsInput{ Namespace: namespace, LabelSelector: batchJobSelector, })