removeJobsByMaxCount.lua 409 B

123456789101112131415
  1. --[[
  2. Functions to remove jobs by max count.
  3. ]]
  4. -- Includes
  5. --- @include "removeJob"
  6. local function removeJobsByMaxCount(maxCount, targetSet, prefix)
  7. local start = maxCount
  8. local jobIds = rcall("ZREVRANGE", targetSet, start, -1)
  9. for i, jobId in ipairs(jobIds) do
  10. removeJob(jobId, false, prefix, false --[[remove debounce key]])
  11. end
  12. rcall("ZREMRANGEBYRANK", targetSet, 0, -(maxCount + 1))
  13. end