add stats about waiting jobs

Author: svenfuchs

lib/travis/scheduler/limit/jobs.rb

@@ -8,7 +8,8 @@ module Limit
         max:       'max jobs for %s by %s: %s',
         max_plan:  'max jobs for %s by %s: %s (%s)',
         max_stage: 'jobs for %s limited at stage: %s (queueable: %s)',
-        summary:   '%s: total: %s, running: %s, queueable: %s'
+        summary:   '%s: total: %s, running: %s, queueable: %s',
+        stats:     'jobs waiting for %s: %s'
       }
 
       class Jobs < Struct.new(:context, :owners)
@@ -26,6 +27,7 @@ def run
           unleak_queueables if ENV['UNLEAK_QUEUEABLE_JOBS']
           check_all
           report summary
+          report stats if waiting.any?
         end
 
         def reports
@@ -77,11 +79,7 @@ def check(job)
           end
 
           def enqueue?(job)
-            limits_for(job).map do |limit|
-              result = limit.enqueue?
-              # report *limit.reports
-              result
-            end.inject(&:&)
+            limits_for(job).map(&:enqueue?).inject(&:&)
           end
 
           def limits_for(job)
@@ -92,10 +90,20 @@ def summary
             MSGS[:summary] % [owners.to_s, queueable.size, state.running_by_owners, selected.size]
           end
 
+          def stats
+            jobs = waiting.group_by(&:repository)
+            stats = jobs.map { |repo, jobs| [repo.slug, jobs.size].join('=') }
+            MSGS[:stats] % [owners.key, stats.join(', ')]
+          end
+
           def report(*reports)
             self.reports.concat(reports).uniq!
           end
 
+          def waiting
+            queueable - selected
+          end
+
           def queueable
             @queueable ||= Job.by_owners(owners.all).queueable.to_a
           end

spec/travis/scheduler/limit_spec.rb

@@ -38,6 +38,7 @@ def create_jobs(count, attrs = {})
     it { expect(subject.size).to eq 2 }
     it { expect(report).to include('max jobs for user svenfuchs by boost: 2') }
     it { expect(report).to include('user svenfuchs: total: 3, running: 0, queueable: 2') }
+    it { expect(report).to include('jobs waiting for svenfuchs: svenfuchs/gem-release=1') }
   end
 
   describe 'with a subscription limit 1' do