X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/27caa99307862e7a37a9f0062d009710d875b320..4a78c361a6de3bcbf98f02abfe41ae3b11de2b00:/lib/workerpool.py diff --git a/lib/workerpool.py b/lib/workerpool.py index 6d533fe..8db03c7 100644 --- a/lib/workerpool.py +++ b/lib/workerpool.py @@ -412,6 +412,16 @@ class WorkerPool(object): return True return False + def HasRunningTasks(self): + """Checks whether there's at least one task running. + + """ + self._lock.acquire() + try: + return self._HasRunningTasksUnlocked() + finally: + self._lock.release() + def Quiesce(self): """Waits until the task queue is empty.