Log task fail
This commit is contained in:
parent
f119f7d0d2
commit
c01245a4e0
1 changed files with 2 additions and 1 deletions
|
@ -571,8 +571,9 @@ class WorkerManager(object):
|
||||||
self.site.greenlet_manager.spawn(self.checkComplete)
|
self.site.greenlet_manager.spawn(self.checkComplete)
|
||||||
|
|
||||||
# Mark a task failed
|
# Mark a task failed
|
||||||
def failTask(self, task):
|
def failTask(self, task, reason="Unknown"):
|
||||||
if task in self.tasks:
|
if task in self.tasks:
|
||||||
|
self.log.debug("Task %s failed (Reason: %s)" % (task["inner_path"], reason))
|
||||||
task["done"] = True
|
task["done"] = True
|
||||||
self.tasks.remove(task) # Remove from queue
|
self.tasks.remove(task) # Remove from queue
|
||||||
self.site.onFileFail(task["inner_path"])
|
self.site.onFileFail(task["inner_path"])
|
||||||
|
|
Loading…
Reference in a new issue