diff --git a/mrq/worker.py b/mrq/worker.py index 9afcd3c0..8d9850ad 100644 --- a/mrq/worker.py +++ b/mrq/worker.py @@ -306,7 +306,7 @@ def get_worker_report(self, with_memory=False): else: io[k] = sorted(v.items(), reverse=True, key=lambda x: x[1]) - used_pool_slots = self.gevent_pool.free_count() - self.pool_size + used_pool_slots = self.pool_size - self.gevent_pool.free_count() return { "status": self.status,