diff --git a/conversion_helpers.go b/conversion_helpers.go index 74e7969..4ba5ef3 100644 --- a/conversion_helpers.go +++ b/conversion_helpers.go @@ -190,7 +190,7 @@ func taskTTL(task *asynq.TaskInfo) time.Duration { if task.State != asynq.TaskStateCompleted { return 0 // N/A } - return task.CompletedAt.Add(task.ResultTTL).Sub(time.Now()) + return task.CompletedAt.Add(task.Retention).Sub(time.Now()) } // formatTimeInRFC3339 formats t in RFC3339 if the value is non-zero.