go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-19 23:30:20 +08:00
Code Issues Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
popstk 2025-01-10 17:39:53 +08:00
parent 489e21920b
commit fea98072d3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/rdb/rdb.go
View File

@ -866,7 +866,7 @@ if redis.call("ZREM", KEYS[3], ARGV[1]) == 0 then
return redis.error_reply("NOT FOUND") return redis.error_reply("NOT FOUND")
end end
redis.call("ZADD", KEYS[4], ARGV[3], ARGV[1]) redis.call("ZADD", KEYS[4], ARGV[3], ARGV[1])
local old = redis.call("ZRANGE", KEYS[4], "-inf", ARGV[4], "BYSCORE") local old = redis.call("ZRANGEBYSCORE", KEYS[4], "-inf", ARGV[4])
if #old > 0 then if #old > 0 then
for _, id in ipairs(old) do for _, id in ipairs(old) do
redis.call("DEL", KEYS[9] .. id) redis.call("DEL", KEYS[9] .. id)