class SidekiqUniqueJobs::Lock

def lock(job_id, lock_info = {})

Returns:
  • (void) -

Parameters:
  • lock_info (Hash) -- information about the lock
  • job_id (String) -- a sidekiq JID

Other tags:
    Note: - intended only for testing purposez
def lock(job_id, lock_info = {})
  redis do |conn|
    conn.multi do
      conn.set(key.digest, job_id)
      conn.hset(key.locked, job_id, now_f)
      info.set(lock_info)
      conn.zadd(key.digests, now_f, key.digest)
      conn.zadd(key.changelog, now_f, changelog_json(job_id, "queue.lua", "Queued"))
      conn.zadd(key.changelog, now_f, changelog_json(job_id, "lock.lua", "Locked"))
    end
  end
end