diff --git a/pulsar/managers/queued.py b/pulsar/managers/queued.py
index 20b6342f2c3bc9c84a0c633d5e3f1ab3d2a4118a..d8bf749cf43f3121ab8a360e29f55b3a0bc7f6e1 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)):