go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-07-05 12:53:40 +08:00
Code Issues Projects Releases Wiki Activity

Fix deleteTask lua script

Browse Source
This commit is contained in:
Ken Hibino 2021-06-18 14:50:28 -07:00
parent 06f8164174
commit 27cbee82e9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/rdb/inspect.go
View File

@ -994,7 +994,7 @@ else
end end
end end
local unique_key = redis.call("HGET", KEYS[1], "unique_key") local unique_key = redis.call("HGET", KEYS[1], "unique_key")
if unique_key ~= nil and unique_key ~= "" and redis.call("GET", unique_key) == ARGV[1] then if unique_key and unique_key ~= "" and redis.call("GET", unique_key) == ARGV[1] then
redis.call("DEL", unique_key) redis.call("DEL", unique_key)
end end
return redis.call("DEL", KEYS[1]) return redis.call("DEL", KEYS[1])
@ -1094,7 +1094,7 @@ local ids = redis.call("ZRANGE", KEYS[1], 0, -1)
for _, id in ipairs(ids) do for _, id in ipairs(ids) do
local task_key = ARGV[1] .. id local task_key = ARGV[1] .. id
local unique_key = redis.call("HGET", task_key, "unique_key") local unique_key = redis.call("HGET", task_key, "unique_key")
if unique_key ~= nil and unique_key ~= "" and redis.call("GET", unique_key) == id then if unique_key and unique_key ~= "" and redis.call("GET", unique_key) == id then
redis.call("DEL", unique_key) redis.call("DEL", unique_key)
end end
redis.call("DEL", task_key) redis.call("DEL", task_key)