58f8093689
- Updated all component headers and documentation
- Changed navbar and footer branding
- Updated homepage hero badge
- Modified page title in index.html
- Simplified footer text to 'Built with ❤️'
- Consistent V2 capitalization across all references
27 lines
634 B
Lua
27 lines
634 B
Lua
--[[
|
|
Drains the queue, removes all jobs that are waiting
|
|
or delayed, but not active, completed or failed
|
|
|
|
Input:
|
|
KEYS[1] 'wait',
|
|
KEYS[2] 'paused'
|
|
KEYS[3] 'delayed'
|
|
KEYS[4] 'prioritized'
|
|
|
|
ARGV[1] queue key prefix
|
|
]]
|
|
local rcall = redis.call
|
|
local queueBaseKey = ARGV[1]
|
|
|
|
--- @include "includes/removeListJobs"
|
|
--- @include "includes/removeZSetJobs"
|
|
|
|
removeListJobs(KEYS[1], true, queueBaseKey, 0) --wait
|
|
removeListJobs(KEYS[2], true, queueBaseKey, 0) --paused
|
|
|
|
if KEYS[3] ~= "" then
|
|
removeZSetJobs(KEYS[3], true, queueBaseKey, 0) --delayed
|
|
end
|
|
|
|
removeZSetJobs(KEYS[4], true, queueBaseKey, 0) --prioritized
|