scheduler: make sure worker exceptions are not unexpectedly hidden.

This commit is contained in:
whitequark 2016-01-16 02:20:32 +00:00
parent 6bf48e60ba
commit 13e65c2a0a

View File

@ -231,7 +231,7 @@ class PrepareStage(TaskObject):
except: except:
logger.error("got worker exception in prepare stage, " logger.error("got worker exception in prepare stage, "
"deleting RID %d", run.rid) "deleting RID %d", run.rid)
logger.debug("worker exception details", exc_info=True) logger.error("worker exception details", exc_info=True)
self.delete_cb(run.rid) self.delete_cb(run.rid)
else: else:
run.status = RunStatus.prepare_done run.status = RunStatus.prepare_done
@ -281,7 +281,7 @@ class RunStage(TaskObject):
except: except:
logger.error("got worker exception in run stage, " logger.error("got worker exception in run stage, "
"deleting RID %d", run.rid) "deleting RID %d", run.rid)
logger.debug("worker exception details", exc_info=True) logger.info("worker exception details", exc_info=True)
self.delete_cb(run.rid) self.delete_cb(run.rid)
else: else:
if completed: if completed: