-- priority(0, jid, priority)
-- --------------------------
-- Accepts a jid, and a new priority for the job. If the job
-- doesn't exist, then return false. Otherwise, return the
-- updated priority. If the job is waiting, then the change
-- will be reflected in the order in which it's popped
if #KEYS ~= 0 then
error('Priority(): Got ' .. #KEYS .. ', expected 0')
end
local jid = assert(ARGV[1] , 'Priority(): Arg "jid" missing')
local priority = assert(tonumber(ARGV[2]), 'Priority(): Arg "priority" missing or not a number: ' .. tostring(ARGV[2]))
-- Get the queue the job is currently in, if any
local queue = redis.call('hget', 'ql:j:' .. jid, 'queue')
if queue == nil then
return false
elseif queue == '' then
-- Just adjust the priority
redis.call('hset', 'ql:j:' .. jid, 'priority', priority)
return priority
else
-- Adjust the priority and see if it's a candidate for updating
-- its priority in the queue it's currently in
if redis.call('zscore', 'ql:q:' .. queue .. '-work', jid) then
redis.call('zadd', 'ql:q:' .. queue .. '-work', priority, jid)
end
redis.call('hset', 'ql:j:' .. jid, 'priority', priority)
return priority
end