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

Merge fea98072d394fdea96c1f2ebc7871df116ac2760 into c327bc40a28e4db45195cfe082d88faa808ce87d

Browse Source
This commit is contained in:
Mark 2025-04-01 09:06:21 +03:00 committed by GitHub
commit bb88ca7e8d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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)