class Rjob::Scripts::ReturnJobExecution
Public Instance Methods
arg_params()
click to toggle source
# File lib/rjob/scripts/return_job_execution.rb, line 4 def arg_params %i(job bucket prefix) end
lua_script()
click to toggle source
# File lib/rjob/scripts/return_job_execution.rb, line 8 def lua_script <<~LUA local job = ARGV[1] local bucket = ARGV[2] local prefix = ARGV[3] local r = redis r.call('lrem', prefix .. ':jobs:' .. bucket .. ':working', 1, job) r.call('rpush', prefix .. ':jobs:' .. bucket, job) return 1 LUA end