Unset assigned_subtask on resource failure

golemfactory · Apr 30, 2019 · b979e5f · b979e5f
1 parent 8246003
commit b979e5f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/golem/task/taskcomputer.py b/golem/task/taskcomputer.py
@@ -123,6 +123,7 @@ def resource_collected(self, res_id):
 
     def resource_failure(self, res_id, reason):
         subtask = self.assigned_subtask
+        self.assigned_subtask = None
         if not subtask or subtask['task_id'] != res_id:
             logger.error("Resource failure for a wrong task, %s", res_id)
             return