go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-14 11:31:18 +08:00
Code Issues Projects Releases Wiki Activity

Fix redis script error

Browse Source
This commit is contained in:
Ken Hibino 2023-01-02 13:17:18 -08:00
parent 0b8cfad703
commit bafed907e9
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/rdb.go
View File

@ -379,7 +379,7 @@ if redis.call("ZREM", KEYS[2], ARGV[1]) == 0 then
return redis.error_reply("NOT FOUND") return redis.error_reply("NOT FOUND")
end end
if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then
redis.redis.error_reply("INTERNAL") return redis.error_reply("INTERNAL")
end end
redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed") redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed")
local n = redis.call("INCR", KEYS[5]) local n = redis.call("INCR", KEYS[5])
@ -416,7 +416,7 @@ if redis.call("ZREM", KEYS[2], ARGV[1]) == 0 then
return redis.error_reply("NOT FOUND") return redis.error_reply("NOT FOUND")
end end
if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then if redis.call("ZADD", KEYS[3], ARGV[3], ARGV[1]) ~= 1 then
redis.redis.error_reply("INTERNAL") return redis.error_reply("INTERNAL")
end end
redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed") redis.call("HSET", KEYS[4], "msg", ARGV[4], "state", "completed")
local n = redis.call("INCR", KEYS[5]) local n = redis.call("INCR", KEYS[5])