Skip to content

Commit 69b7a83

Browse files
committed
Use cleaner Job.joins approach for processing count
Inspired by judoscale's implementation - query from Job table since queue_name is directly on Job, avoiding explicit table name reference.
1 parent 660f149 commit 69b7a83

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/cloud66/metrics/solid_queue.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,8 @@ def queue_array_concrete
3131
solid_queue_waiting = solid_queue_pending.merge(solid_queue_due_scheduled) { |_key, ready, scheduled| ready + scheduled }
3232

3333
# Get processing jobs per queue from claimed executions
34-
# ClaimedExecution doesn't have queue_name directly, need to join with job
35-
solid_queue_working = ::SolidQueue::ClaimedExecution.joins(:job).group("solid_queue_jobs.queue_name").count
34+
# Using Job.joins approach since queue_name is directly on Job
35+
solid_queue_working = ::SolidQueue::Job.joins(:claimed_execution).group(:queue_name).count
3636

3737
result = []
3838
solid_queue_queue_names = solid_queue_waiting.keys | solid_queue_working.keys

0 commit comments

Comments
 (0)