diff --git a/lib/commands/cleanJobsInSet-1.lua b/lib/commands/cleanJobsInSet-1.lua index 88e9f020d..0a3e75536 100644 --- a/lib/commands/cleanJobsInSet-1.lua +++ b/lib/commands/cleanJobsInSet-1.lua @@ -37,6 +37,7 @@ for _, job in ipairs(jobs) do redis.call("ZREM", KEYS[1], job) end redis.call("DEL", jobKey) + redis.call("DEL", jobKey .. ":logs") deletedCount = deletedCount + 1 table.insert(deleted, job) end