diff --git a/lib/promenade/pitchfork/stats.rb b/lib/promenade/pitchfork/stats.rb index ee474a5..1394897 100644 --- a/lib/promenade/pitchfork/stats.rb +++ b/lib/promenade/pitchfork/stats.rb @@ -27,8 +27,8 @@ def initialize raindrops_stats = Raindrops::Stats.new - @active_workers = raindrops_stats.active_workers - @queued_requests = raindrops_stats.queued_requests + @active_workers = raindrops_stats.active_workers || 0 + @queued_requests = raindrops_stats.queued_requests || 0 end def instrument @@ -47,16 +47,13 @@ def self.instrument attr_reader :workers_count, :live_workers_count, :active_workers, :queued_requests def capacity - return 0 if live_workers_count.nil? || active_workers.nil? - return 0 if live_workers_count&.zero? - return 0 if active_workers&.zero? + return 0 if live_workers_count.nil? || live_workers_count.zero? live_workers_count - active_workers end def busy_percent - return 100 if live_workers_count.zero? - return 100 if active_workers&.zero? + return 0 if live_workers_count.zero? (active_workers.to_f / live_workers_count) * 100 end