-- KEYS[1]: this consumer's inflight set
-- KEYS[2]: the active jobs list
-- KEYS[3]: the signal list

-- ARGV[]: the list of job IDs

-- Returns: nil

for _,job_id in ipairs(ARGV) do
  -- Remove the jobs from this consumer's inflight set
  local removed = redis.call("srem", KEYS[1], job_id)

  if removed == 1 then
    -- Push the job back into the active jobs list
    redis.call("rpush", KEYS[2], job_id)
  end
end

-- Signal that there are jobs in the queue
redis.call("del", KEYS[3])
redis.call("lpush", KEYS[3], 1)

return true