diff --git a/golem/task/taskcomputer.py b/golem/task/taskcomputer.py index 2afa63c3a3..3b1806eab9 100644 --- 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