DJ (delayed_jobs) queue check

dj_check.sql

select
if(locate('PerformableMethod', s1) > 0,
    if(locate('method_name', s3) > 0,
        s3,
        s2
    ),
    s1
) s,
sum(run_at <= now()) as total_waiting, -- date_add(now(), interval 8 hour))
min(priority),
count(1) as total,
sum(run_at > now()) as total_scheduled_for_later, -- date_add(now(), interval 8 hour))
max(priority),
min(run_at),
queue
from
(
    select
    substring_index(handler, "\n", 1) s1,
    substring_index(handler, "\n", 2) s2,
    substring_index(handler, "\n", 3) s3,
    handler,
    run_at,
    priority,
        queue
    from delayed_jobs
) d
group by s
order by total_waiting desc;