fix retry message

Signed-off-by: Mikhail Scherba <mikhail.scherba@flant.com>
flant · Jan 21, 2025 · 3bf2dc5 · 3bf2dc5
1 parent 977d9fa
commit 3bf2dc5
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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()
+		waitSeconds := 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", waitSeconds.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-waitSeconds).String(), delay.String())
 		}
 	}
 }