master/scheduler: reduce logging severity of worker exception backtraces to debug

This commit is contained in:
Sebastien Bourdeauducq 2015-10-28 17:48:50 +08:00
parent 1ada15ae5d
commit 828b48ad89
1 changed files with 6 additions and 6 deletions

View File

@ -229,8 +229,8 @@ class PrepareStage(TaskObject):
await run.prepare() await run.prepare()
except: except:
logger.error("got worker exception in prepare stage, " logger.error("got worker exception in prepare stage, "
"deleting RID %d", "deleting RID %d", run.rid)
run.rid, exc_info=True) logger.debug("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
@ -279,8 +279,8 @@ class RunStage(TaskObject):
completed = await run.run() completed = await run.run()
except: except:
logger.error("got worker exception in run stage, " logger.error("got worker exception in run stage, "
"deleting RID %d", "deleting RID %d", run.rid)
run.rid, exc_info=True) logger.debug("worker exception details", exc_info=True)
self.delete_cb(run.rid) self.delete_cb(run.rid)
else: else:
if completed: if completed:
@ -317,8 +317,8 @@ class AnalyzeStage(TaskObject):
await run.write_results() await run.write_results()
except: except:
logger.error("got worker exception in analyze stage, " logger.error("got worker exception in analyze stage, "
"deleting RID %d", "deleting RID %d", run.rid)
run.rid, exc_info=True) logger.debug("worker exception details", exc_info=True)
self.delete_cb(run.rid) self.delete_cb(run.rid)
else: else:
self.delete_cb(run.rid) self.delete_cb(run.rid)