Contents

local unique_key = KEYS[1]
local job_id     = ARGV[1]
local expires    = ARGV[2]
local stored_jid = redis.pcall('get', unique_key)

if stored_jid then
  if stored_jid == job_id then
    return 1
  else
    return 0
  end
end

if redis.pcall('set', unique_key, job_id, 'nx', 'ex', expires) then
  -- redis.pcall('hsetnx', 'uniquejobs', job_id, unique_key)
  return 1
else
  return 0
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-5.0.11	redis/acquire_lock.lua