go-pkg/asynqmon
2
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-10-03 10:42:00 +08:00
Code Issues Projects Releases Wiki Activity

Update conversion_helper

Browse Source
This commit is contained in:
Ken Hibino
2021-11-05 16:50:29 -07:00
parent fe5bd2f3e8
commit f3ec23d100
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
conversion_helpers.go
View File

@@ -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.