| 123456789101112131415161718192021 |
- -- Includes
- --- @include "batches"
- --- @include "filterOutJobsToIgnore"
- --- @include "getZSetItems"
- --- @include "removeJobs"
- local function removeZSetJobs(keyName, hard, baseKey, max, jobsToIgnore)
- local jobs = getZSetItems(keyName, max)
- if jobsToIgnore then
- jobs = filterOutJobsToIgnore(jobs, jobsToIgnore)
- end
- local count = removeJobs(jobs, hard, baseKey, max)
- if(#jobs > 0) then
- for from, to in batches(#jobs, 7000) do
- rcall("ZREM", keyName, unpack(jobs, from, to))
- end
- end
- return count
- end
|