Use subtask timeout status in taskmanager (#5136)

golemfactory · Mar 19, 2020 · c76c673 · c76c673
1 parent 64596e2
commit c76c673
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/golem/task/taskmanager.py b/golem/task/taskmanager.py
@@ -924,7 +924,7 @@ def check_timeouts(self):
                         logger.info("Subtask %r dies with status %r",
                                     s.subtask_id,
                                     s.status.value)
-                        s.status = SubtaskStatus.failure
+                        s.status = SubtaskStatus.timeout
                         nodes_with_timeouts.append(s.node_id)
                         t.computation_failed(s.subtask_id)
                         s.stderr = "[GOLEM] Timeout"

diff --git a/tests/golem/task/test_taskmanager.py b/tests/golem/task/test_taskmanager.py
@@ -839,7 +839,7 @@ def test_check_timeouts(self, *_):
             )
             self.assertIs(
                 task_state.subtask_states["aabbcc"].status,
-                SubtaskStatus.failure,
+                SubtaskStatus.timeout,
             )
         # Task with task and subtask timeout
         with patch('golem.task.taskbase.Task.needs_computation',
@@ -869,7 +869,7 @@ def test_check_timeouts(self, *_):
             )
             self.assertIs(
                 task_state.subtask_states["qwerty"].status,
-                SubtaskStatus.failure,
+                SubtaskStatus.timeout,
             )
             checker([("qwe", "qwerty", SubtaskOp.TIMEOUT),
                      ("qwe", None, TaskOp.TIMEOUT)])