diff --git a/jobManager.py b/jobManager.py index 7ec31aee..b72b6d6f 100644 --- a/jobManager.py +++ b/jobManager.py @@ -102,7 +102,10 @@ def __manage(self): ).start() except Exception as err: - self.jobQueue.makeDead(job.id, str(err)) + if job: + self.jobQueue.makeDead(job.id, str(err)) + else: + self.log.info("Missing job %s, error: %s" % (str(id), str(err))) # Sleep for a bit and then check again time.sleep(Config.DISPATCH_PERIOD)