apalis-redis 1.0.0

Background task processing for rust using apalis and redis
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
27
28
29
30
31
32
33
34
35

-- KEYS[1]: the task data hash
-- KEYS[2]: the metadata prefix (e.g. "task_meta")
-- ARGV[1]: duration in seconds

local terminal_statuses = {
  Done = true,
  Failed = true,
  Killed = true
}

local result_hash = KEYS[2] .. ":result"
local cutoff = redis.call("TIME")[1] - tonumber(ARGV[1])
local deleted = 0

local fields = redis.call("hgetall", KEYS[1])

-- fields is a flat list of [field, value, field, value, ...]
for i = 1, #fields, 2 do
  local task_id = fields[i]
  local meta_key = KEYS[2] .. ':' .. task_id

  local status = redis.call("hget", meta_key, "status")
  local done_at = redis.call("hget", meta_key, "done_at")

  if status and terminal_statuses[status] and done_at then
    if tonumber(done_at) <= cutoff then
      redis.call("hdel", KEYS[1], task_id)
      redis.call("hdel", result_hash, task_id)
      redis.call("del", meta_key)
      deleted = deleted + 1
    end
  end
end

return deleted