From 88e6654a6c29db2bfd700523dd771e6b5d38fb93 Mon Sep 17 00:00:00 2001
From: Richard Robert Reitz <richard-robert.reitz@telekom.de>
Date: Wed, 29 Oct 2025 11:12:12 +0100
Subject: [PATCH] feat(runner): Added waiting for a job arrival in the one-job
 command.

---
 internal/app/job/job.go | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/internal/app/job/job.go b/internal/app/job/job.go
index 6babd498..654bc154 100644
--- a/internal/app/job/job.go
+++ b/internal/app/job/job.go
@@ -36,11 +36,20 @@ func NewJob(cfg *config.Config, client client.Client, runner run.RunnerInterface
 }
 
 func (j *Job) Run(ctx context.Context) error {
-	task, ok := j.fetchTask(ctx)
-	if !ok {
-		return fmt.Errorf("could not fetch task")
+	log.Info("Polling for a job...")
+	for {
+		task, ok := j.fetchTask(ctx)
+		if ok {
+			return j.runTaskWithRecover(ctx, task)
+		}
+		// No task available, continue polling
+		select {
+		case <-ctx.Done():
+			return ctx.Err()
+		default:
+			// Continue to next iteration
+		}
 	}
-	return j.runTaskWithRecover(ctx, task)
 }
 
 func (j *Job) runTaskWithRecover(ctx context.Context, task *runnerv1.Task) error {