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
24
25
26

-- Lua script to clean up data in Redis

-- Define the keys
local done_list_key = KEYS[1]
local data_hash = KEYS[2]

-- Iterate through done_list
local done_list_ids = redis.call('ZRANGE', done_list_key, 0, -1)

-- Initialize a variable to count the number of removed items
local removed_items_count = 0

for _, id in ipairs(done_list_ids) do

    local is_member = redis.call('HEXISTS', data_hash, id)
    if is_member == 1 then
        -- Remove entry from data_hash
        redis.call('HDEL', data_hash, id)
        removed_items_count = removed_items_count + 1
    end
end

-- Clean the done_list
redis.call('DEL', done_list_key)

return removed_items_count