From 8be71a6a2dc019da62451a0a7c7d974d7fe784d4 Mon Sep 17 00:00:00 2001 From: yalosev Date: Tue, 21 Jan 2025 17:56:00 +0400 Subject: [PATCH] Fixes the queue retry delay counter message so that it correctly posts how many seconds left till next retry. Signed-off-by: Yuriy Losev --- pkg/task/queue/task_queue.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/task/queue/task_queue.go b/pkg/task/queue/task_queue.go index 44e64bc8..724534ea 100644 --- a/pkg/task/queue/task_queue.go +++ b/pkg/task/queue/task_queue.go @@ -563,12 +563,12 @@ func (q *TaskQueue) waitForTask(sleepDelay time.Duration) task.Task { } // Wait loop still in progress: update queue status. - waitSeconds := time.Since(waitBegin).Truncate(time.Second).String() + waitTime := time.Since(waitBegin).Truncate(time.Second) if sleepDelay == 0 { - q.Status = fmt.Sprintf("waiting for task %s", waitSeconds) + q.Status = fmt.Sprintf("waiting for task %s", waitTime.String()) } else { - delay := sleepDelay.Truncate(time.Second).String() - q.Status = fmt.Sprintf("%s (%s left of %s delay)", origStatus, waitSeconds, delay) + delay := sleepDelay.Truncate(time.Second) + q.Status = fmt.Sprintf("%s (%s left of %s delay)", origStatus, (delay - waitTime).String(), delay.String()) } } }