Class: Rjob::Scripts::RetryJob

Inherits:
RedisScript show all
Defined in:
lib/rjob/scripts/retry_job.rb

Instance Attribute Summary

Attributes inherited from RedisScript

#sha1

Instance Method Summary collapse

Methods inherited from RedisScript

#key_params

Instance Method Details

#arg_params ⇒ Object 



4
5
6
 
# File 'lib/rjob/scripts/retry_job.rb', line 4

def arg_params
  i(next_retry_at retry_num bucket job_id job_payload prefix)
end

#lua_script ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/rjob/scripts/retry_job.rb', line 8

def lua_script
  "    local timestamp = ARGV[1]\n    local retry_num = ARGV[2]\n    local bucket = ARGV[3]\n    local job_id = ARGV[4]\n    local job_payload = ARGV[5]\n    local prefix = ARGV[6]\n    local r = redis\n\n    local curr_job = job_id .. '!' .. retry_num .. '!' .. job_payload\n    local new_job = job_id .. '!' .. (retry_num + 1) .. '!' .. job_payload\n\n    r.call('lrem', prefix .. ':jobs:' .. bucket .. ':working', 1, curr_job)\n    r.call('zadd', prefix .. ':scheduled:' .. bucket, timestamp, new_job)\n\n    return job_id\n  LUA\nend\n"