From 62d4edadf6553ff0d97f8062c88a553cfbaed3de Mon Sep 17 00:00:00 2001
From: shortcutme <tamas@zeronet.io>
Date: Sat, 21 Dec 2019 02:57:53 +0100
Subject: [PATCH] Fail task if no peer left to try

---
 src/Worker/WorkerManager.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py
index 932f9d6a..5b69ceeb 100644
--- a/src/Worker/WorkerManager.py
+++ b/src/Worker/WorkerManager.py
@@ -539,6 +539,9 @@ class WorkerManager(object):
             self.tasks.updateItem(task, "workers_num", task["workers_num"] - 1)
         else:
             task["workers_num"] -= 1
+        if len(task["failed"]) >= len(self.workers):
+            fail_reason = "Too many fails: %s (workers: %s)" % (len(task["failed"]), len(self.workers))
+            self.failTask(task, reason=fail_reason)
 
     # Wait for other tasks
     def checkComplete(self):