ActiveJob
でqueue adaptorにSidekiq
を使ってて、ジョブの状況を確認したいので調査しました
環境
sidekiq (5.1.1)
コード
# 処理中のjob
workers = Sidekiq::Workers.new
workers.each do |_process_id, _thread_id, work|
p work
end
# 処理待ちのjob
queues = Sidekiq::Queue.all
queues.each do |queue|
queue.each do |job|
p job.klass, job.args, job.jid
end
end
以上です