apalis-redis 0.7.4

Redis Storage for apalis: use Redis for background jobs and message queueing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

-- 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