From 77ded502ab49d1f0e722335fa7837bdf0218151d Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Mon, 26 Apr 2021 07:10:29 -0700 Subject: [PATCH] Update RDB.Retry, RDB.Archive with task state --- internal/rdb/rdb.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 01c63ee..bfa9e42 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -444,7 +444,7 @@ if redis.call("ZREM", KEYS[3], ARGV[1]) == 0 then return redis.error_reply("NOT FOUND") end redis.call("ZADD", KEYS[4], ARGV[3], ARGV[1]) -redis.call("HSET", KEYS[1], "msg", ARGV[2]) +redis.call("HSET", KEYS[1], "msg", ARGV[2], "state", "retry") local n = redis.call("INCR", KEYS[5]) if tonumber(n) == 1 then redis.call("EXPIREAT", KEYS[5], ARGV[4]) @@ -511,7 +511,7 @@ end redis.call("ZADD", KEYS[4], ARGV[3], ARGV[1]) redis.call("ZREMRANGEBYSCORE", KEYS[4], "-inf", ARGV[4]) redis.call("ZREMRANGEBYRANK", KEYS[4], 0, -ARGV[5]) -redis.call("HSET", KEYS[1], "msg", ARGV[2]) +redis.call("HSET", KEYS[1], "msg", ARGV[2], "state", "archived") local n = redis.call("INCR", KEYS[5]) if tonumber(n) == 1 then redis.call("EXPIREAT", KEYS[5], ARGV[6])