From 1d1bf323c103a4c90236c8da7dd4d438ec5023ea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Praszmo?= Date: Mon, 11 Mar 2024 14:09:48 +0100 Subject: [PATCH] Use error instead of warning when tasks are killed due to inactivity --- karton/system/system.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/karton/system/system.py b/karton/system/system.py index a56f939..18e2adf 100644 --- 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,