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

-- KEYS[1]: this consumer's inflight set
-- KEYS[2]: the dead jobs set
-- KEYS[3]: the job data hash
-- ARGV[1]: the job ID
-- ARGV[2]: the current time
-- ARGV[3]: the result of the job
-- Returns: nil
-- Remove the job from this consumer's inflight set
local removed = redis.call("srem", KEYS[1], ARGV[1])

if removed == 1 then
    -- Push the job on to the dead jobs set
    redis.call("zadd", KEYS[2], ARGV[2], ARGV[1])

    -- Save the result of the job
    local ns = "::result"
    redis.call("hmset", KEYS[3] .. ns, ARGV[1], ARGV[3])

    return 1
end

return 0