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()) } } }