diff --git a/src/commands/cleanJobsInSet-1.lua b/src/commands/cleanJobsInSet-1.lua index ae226ca743..7735e14c3e 100644 --- a/src/commands/cleanJobsInSet-1.lua +++ b/src/commands/cleanJobsInSet-1.lua @@ -39,6 +39,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