From cd254fd7918e3628e3c9736000c70f0e17502cfc Mon Sep 17 00:00:00 2001 From: bstriner Date: Sun, 18 Mar 2018 16:11:06 -0400 Subject: [PATCH 1/2] Fix crash on missing job --- jobManager.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/jobManager.py b/jobManager.py index 7ec31aee..24b48ee1 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 %d, error: %s" % (id, str(err))) # Sleep for a bit and then check again time.sleep(Config.DISPATCH_PERIOD) From 53d2ea9946e02a0739724678afe21dd7dc774af1 Mon Sep 17 00:00:00 2001 From: bstriner Date: Sun, 18 Mar 2018 17:10:03 -0400 Subject: [PATCH 2/2] Just in case id is None too. --- jobManager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/jobManager.py b/jobManager.py index 24b48ee1..b72b6d6f 100644 --- a/jobManager.py +++ b/jobManager.py @@ -105,7 +105,7 @@ def __manage(self): if job: self.jobQueue.makeDead(job.id, str(err)) else: - self.log.info("Missing job %d, error: %s" % (id, str(err))) + 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)