Delayed::Job Scopes

delayed_job_scopes.rb

module DelayedJobScopes
  extend ActiveSupport::Concern

  included do
    scope :error, -> (error) { failed.where('last_error ILIKE (?)', "%#{error.strip}%") }
    scope :failed, -> { where('last_error IS NOT NULL') }
    scope :queues, -> (queues) { where(queue: queues) }
  end

  def id_in_args
    regex = /args\D+(\d*)/
    match = regex.match(handler)
    match[1] if match
  end
end
Delayed::Job.send(:include, DelayedJobScopes)