diff --git a/lib/jqueue.py b/lib/jqueue.py index 6d2e435fb7871d4f3235969cb10089e1db3a91f6..f8f9fd87286bb08d396ab96817853d6230ec4745 100644 --- a/lib/jqueue.py +++ b/lib/jqueue.py @@ -432,22 +432,19 @@ class _QueuedJob(object): """ status = self.CalcStatus() - if status not in (constants.JOB_STATUS_QUEUED, - constants.JOB_STATUS_WAITLOCK): - logging.debug("Job %s is no longer waiting in the queue", self.id) - return (False, "Job %s is no longer waiting in the queue" % self.id) - if status == constants.JOB_STATUS_QUEUED: self.MarkUnfinishedOps(constants.OP_STATUS_CANCELED, "Job canceled by request") - msg = "Job %s canceled" % self.id + return (True, "Job %s canceled" % self.id) elif status == constants.JOB_STATUS_WAITLOCK: # The worker will notice the new status and cancel the job self.MarkUnfinishedOps(constants.OP_STATUS_CANCELING, None) - msg = "Job %s will be canceled" % self.id + return (True, "Job %s will be canceled" % self.id) - return (True, msg) + else: + logging.debug("Job %s is no longer waiting in the queue", self.id) + return (False, "Job %s is no longer waiting in the queue" % self.id) class _OpExecCallbacks(mcpu.OpExecCbBase):