From 28f1d891423a0092d55f955eb4234b9b3e7faee8 Mon Sep 17 00:00:00 2001
From: John Chilton <jmchilton@gmail.com>
Date: Fri, 10 Apr 2015 15:49:07 -0400
Subject: [PATCH] Properly fail job recovery for locally managed jobs.
Will help ensure these jobs eventually become terminal.
---
pulsar/managers/queued.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar/managers/queued.py b/pulsar/managers/queued.py
index 20b6342f..d8bf749c 100644
--- a/pulsar/managers/queued.py
+++ b/pulsar/managers/queued.py
@@ -56,6 +56,8 @@ class QueueManager(Manager):
command_line = self._job_directory(job_id).load_metadata(JOB_FILE_COMMAND_LINE, None)
if command_line:
self.work_queue.put((RUN, (job_id, command_line)))
+ else:
+ raise Exception("Cannot recover job with id %s" % job_id)
def shutdown(self, timeout=None):
for i in range(len(self.work_threads)):
--
GitLab