lib/rocket_job/performance.rb in rocketjob-3.0.0.beta vs lib/rocket_job/performance.rb in rocketjob-3.0.0.beta2
- old
+ new
@@ -21,10 +21,10 @@
self.worker_processes = 0
self.worker_threads = 0
RocketJob::Server.running.each do |worker_process|
unless worker_process.zombie?
self.worker_processes += 1
- self.worker_threads += worker_process.heartbeat.current_threads
+ self.worker_threads += worker_process.heartbeat.workers
end
end
puts "Running: #{worker_threads} workers, distributed across #{worker_processes} processes"
puts 'Waiting for workers to pause'