Class: Sidekiq::LockableJob::Middleware::Server::UnsetLocks

Inherits:

Object

• Object
• Sidekiq::LockableJob::Middleware::Server::UnsetLocks

Defined in:

lib/sidekiq/lockable_job/middleware/server/unset_locks.rb

Instance Method Summary

• #call(worker, job, queue) { ... } ⇒ Void

Instance Method Details

#call(worker, job, queue) { ... } ⇒ Void

Parameters:

• worker (Object) —

  the worker instance

• job (Hash) —

  the full job payload

  • @see github.com/mperham/sidekiq/wiki/Job-Format

• queue (String) —

  the name of the queue the job was pulled from

Yields:

• the next middleware in the chain or worker ‘perform` method

Returns:

• (Void)

# File 'lib/sidekiq/lockable_job/middleware/server/unset_locks.rb', line 14

def call(worker, job, queue)
  yield
  worker_klass = worker.class
  if worker_klass.respond_to?(:lockable_job_unlock_keys)
    keys = worker_klass.send(:lockable_job_unlock_keys, job['args'])
    keys = [keys] unless keys.nil? || keys.is_a?(Array)
    keys&.compact&.each do |key|
      worker_klass.current_lockable_job_lock_service.unlock(key)
    end
  end
end