X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/116db7c709e081e5dba82f1fb5a4b26788156715..3efa9051e5fab3e286fdc293986026fb3cc08b2c:/lib/workerpool.py diff --git a/lib/workerpool.py b/lib/workerpool.py index 3a07165..54b3fb7 100644 --- a/lib/workerpool.py +++ b/lib/workerpool.py @@ -214,7 +214,7 @@ class WorkerPool(object): """ self._lock.acquire() try: - return self._ShouldWorkerTerminateUnlocked(self) + return self._ShouldWorkerTerminateUnlocked(worker) finally: self._lock.release() @@ -305,7 +305,7 @@ class WorkerPool(object): elif current_count < num_workers: # Create (num_workers - current_count) new workers - for i in xrange(num_workers - current_count): + for _ in xrange(num_workers - current_count): worker = self._worker_class(self, self._NewWorkerIdUnlocked()) self._workers.append(worker) worker.start()