From 60750b5c55f080a6b8085ee5a43fb2def317f930 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Sat, 19 Jun 2021 06:45:57 -0700 Subject: [PATCH] Fix LastFailedAt in archived tasks --- tools/asynq/cmd/migrate.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/tools/asynq/cmd/migrate.go b/tools/asynq/cmd/migrate.go index 56ed70d..437ba13 100644 --- a/tools/asynq/cmd/migrate.go +++ b/tools/asynq/cmd/migrate.go @@ -290,6 +290,11 @@ return 1 // ZAddTask adds task to zset. func ZAddTask(c redis.UniversalClient, key string, msg *base.TaskMessage, score float64, state string) error { + // Special case; LastFailedAt field is new so assign a value inferred from zscore. + if state == "archived" { + msg.LastFailedAt = int64(score) + } + encoded, err := base.EncodeMessage(msg) if err != nil { return err