class SidekiqUniqueJobs::Lock
def lock(job_id, lock_info = {})
-
(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