diff --git a/lib/jqueue.py b/lib/jqueue.py index bd4d98625e34279414fc11dc971a3dc27e8ea5d0..fe61c22ee83672d0093565d741838f564ac2b3e0 100644 --- a/lib/jqueue.py +++ b/lib/jqueue.py @@ -945,11 +945,11 @@ class JobQueue(object): status = job.CalcStatus() - if status in (constants.JOB_STATUS_QUEUED, ): + if status in (constants.JOB_STATUS_QUEUED, + constants.JOB_STATUS_WAITLOCK): self._wpool.AddTask((job, )) elif status in (constants.JOB_STATUS_RUNNING, - constants.JOB_STATUS_WAITLOCK, constants.JOB_STATUS_CANCELING): logging.warning("Unfinished job %s found: %s", job.id, job) job.MarkUnfinishedOps(constants.OP_STATUS_ERROR,