Figure out WTF is in our delayed_job queue

delayed_job_classifier.sql

SELECT
count(*) as count, priority, object, method from (
  SELECT
  @load_start := LOCATE('object: LOAD;', handler),
  @method_start := LOCATE('method: ', handler) + 9,
  @method_end := LOCATE('args:', handler) - 1,
  IF(@load_start,
    @object_start := @load_start + 13,
    @object_start := LOCATE('object: !ruby/object:', handler) + 21
  ),
  IF(@load_start,
    @object_end := @method_start - 10,
    @object_end := LOCATE('id: ', handler) - 3
  ),
  priority,
  RTRIM(SUBSTRING_INDEX(SUBSTRING(handler, @object_start, @object_end - @object_start), ';', 1)) as object,
  RTRIM(SUBSTRING(handler, @method_start, @method_end - @method_start)) as method
  FROM delayed_jobs
  WHERE run_at <= UTC_TIMESTAMP()
  AND failed_at IS NULL
  AND priority > -100
) jobs
GROUP BY priority, object, method
ORDER BY count DESC;

move_failed_jobs.sql

BEGIN;

INSERT INTO failed_delayed_jobs (SELECT * FROM delayed_jobs WHERE failed_at IS NOT NULL);

DELETE FROM delayed_jobs WHERE failed_at IS NOT NULL;

COMMIT;