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