module ActiveJob::Locks::Callbacks

Private Instance Methods

lock_resource(payload) click to toggle source
# File lib/active_job/locks/callbacks.rb, line 20
def lock_resource(payload)
  [queue_name, payload_key(payload)].join(":")
end
payload_key(payload) click to toggle source
# File lib/active_job/locks/callbacks.rb, line 13
def payload_key(payload)
  return nil unless payload_lock
  payload.flat_map do |argument|
    argument.respond_to?(:to_global_id) ? argument.to_global_id.uri.to_s : argument.to_s
  end
end
redis_lock() click to toggle source
# File lib/active_job/locks/callbacks.rb, line 9
def redis_lock
  @redis_lock ||= Redlock::Client.new(redis)
end