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