Resque statistics hacks

resque-stat-hacks.rb

def failures_with_ids(n)
  Resque::Failure.all(0,n).each_with_index.map { |ex, i| ex['id'] = i; ex }
end

def group_by_exception(failures)
  failures.reduce({}) do |acc, ex|
    acc[ex['exception']] ||= []
    acc[ex['exception']] << ex
    acc
  end
end

def group_by_class(failures)
  failures.reduce({}) do |acc, ex|
    acc[ex['payload']['class']] ||= []
    acc[ex['payload']['class']] << ex
    acc
  end
end

def value_counts(grouped_failures)
  Hash[grouped_failure.map { |key, exs| [key, exs.size] }]
end