Remove resque jobs if match a condition

remove_jobs.rb

def remove_failed_jobs_if(&block)
  i = 0
  while i < Resque::Failure.count
    job = Resque::Failure.all(i)
    if yield job
      Resque::Failure.remove(i)
    else
      i += 1
    end
  end
end


# Example usage

remove_failed_jobs_if { |job| job['queue'] == 'cache_warmer' }