Use error instead of warning when tasks are killed due to inactivity (#…

…248)
CERT-Polska · Mar 11, 2024 · c7932af · c7932af
1 parent 9964de1
commit c7932af
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/karton/system/system.py b/karton/system/system.py
@@ -103,7 +103,7 @@ def gc_collect_tasks(self) -> None:
                 and current_time > task.last_update + self.task_dispatched_timeout
             ):
                 to_delete.append(task)
-                self.log.warning(
+                self.log.error(
                     "Task %s is in Dispatched state more than %d seconds. "
                     "Killed. (origin: %s)",
                     task.uid,
@@ -116,7 +116,7 @@ def gc_collect_tasks(self) -> None:
                 and current_time > task.last_update + self.task_started_timeout
             ):
                 to_delete.append(task)
-                self.log.warning(
+                self.log.error(
                     "Task %s is in Started state more than %d seconds. "
                     "Killed. (receiver: %s)",
                     task.uid,