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'