queue.clean should clean job logs as well

#1599
OptimalBits · Jan 1, 2020 · 5b6a119 · 5b6a119
1 parent 4517dab
commit 5b6a119
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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