Contents

module SidekiqUniqueJobs
  module Unlockable
    module_function

    def unlock(item)
      unlock_by_key(item[UNIQUE_DIGEST_KEY], item[JID_KEY])
    end

    def unlock_by_key(unique_key, jid, redis_pool = nil)
      Scripts.call(:release_lock, redis_pool, keys: [unique_key], argv: [jid]) do |result|
        after_unlock(result, __method__)
      end
    end

    def unlock_by_jid(jid, redis_pool = nil)
      Scripts.call(:release_lock_by_jid, redis_pool, keys: [jid]) do |result|
        after_unlock(result, __method__)
      end
    end

    def unlock_by_arguments(_worker_class, _unique_arguments = {})
      Scripts.call(:release_lock, redis_pool, keys: [unique_key], argv: [jid]) do |result|
        after_unlock(result, __method__)
      end
    end

    def after_unlock(result, calling_method)
      case result
      when 1
        logger.debug { "successfully unlocked #{unique_key}" }
        true
      when 0
        logger.debug { "expiring lock #{unique_key} is not owned by #{jid}" }
        false
      when -1
        logger.debug { "#{unique_key} is not a known key" }
        false
      else
        raise "#{calling_method} returned an unexpected value (#{result})"
      end
    end

    def logger
      Sidekiq.logger
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-4.0.18	lib/sidekiq_unique_jobs/unlockable.rb
sidekiq-unique-jobs-4.0.17	lib/sidekiq_unique_jobs/unlockable.rb
sidekiq-unique-jobs-4.0.16	lib/sidekiq_unique_jobs/unlockable.rb
sidekiq-unique-jobs-4.0.15	lib/sidekiq_unique_jobs/unlockable.rb