joeyAghion · April 8, 2018 02:14
diff --git a/delayed_jobs_by_queue_and_priority.rb b/delayed_jobs_by_queue_and_priority.rb

 # Number of queued jobs per queue and priority
 pp Delayed::Job.distinct(:queue).sort.map{|q| Delayed::Job.where(queue: q).distinct(:priority).sort.map{|p| [q, p, Delayed::Job.where(queue: q, priority: p).count] } }.sort; nil

 # First 20 jobs, in order that workers dequeue them
 pp Delayed::Job.where(:run_at.lte => Time.now.utc, failed_at: nil).any_of({locked_by: /worker/}, {locked_at: nil}, {locked_at: {'$lt' => (Time.now.utc - 14400)}}).any_in(queue: %w{any imgs}).desc(:locked_by).asc(:priority).asc(:run_at).limit(20).map{|j| [j.id, j.handler.inspect[0..250], j.locked_by, j.run_at, (Time.now.utc - j.locked_at if j.locked_at)] }; nil

	# Number of queued jobs per queue and priority
	pp Delayed::Job.distinct(:queue).sort.map{\|q\| Delayed::Job.where(queue: q).distinct(:priority).sort.map{\|p\| [q, p, Delayed::Job.where(queue: q, priority: p).count] } }.sort; nil

	# First 20 jobs, in order that workers dequeue them
	pp Delayed::Job.where(:run_at.lte => Time.now.utc, failed_at: nil).any_of({locked_by: /worker/}, {locked_at: nil}, {locked_at: {'$lt' => (Time.now.utc - 14400)}}).any_in(queue: %w{any imgs}).desc(:locked_by).asc(:priority).asc(:run_at).limit(20).map{\|j\| [j.id, j.handler.inspect[0..250], j.locked_by, j.run_at, (Time.now.utc - j.locked_at if j.locked_at)] }; nil
No results found