diff --git a/src/Worker/Worker.py b/src/Worker/Worker.py index b7111ba1..9adba30d 100644 --- a/src/Worker/Worker.py +++ b/src/Worker/Worker.py @@ -7,6 +7,8 @@ from Debug import Debug from Config import config from Content.ContentManager import VerifyError +import traceback + class WorkerDownloadError(Exception): pass @@ -119,13 +121,15 @@ class Worker(object): self.manager.log.error("%s: Error writing: %s (%s: %s)" % (self.key, task["inner_path"], type(err), err)) raise WorkerIOError(str(err)) - def onTaskVerifyFail(self, task, error_message): + def onTaskVerifyFail(self, task, error): self.num_failed += 1 if self.manager.started_task_num < 50 or config.verbose: - self.manager.log.debug( + self.manager.log.info( "%s: Verify failed: %s, error: %s, failed peers: %s, workers: %s" % - (self.key, task["inner_path"], error_message, len(task["failed"]), task["workers_num"]) + (self.key, task["inner_path"], error, len(task["failed"]), task["workers_num"]) ) + # traceback.format_ + self.manager.log.debug(''.join(traceback.format_exception(error))) task["failed"].append(self.peer) self.peer.hash_failed += 1 if self.peer.hash_failed >= max(len(self.manager.tasks), 3) or self.peer.connection_error > 10: