From 13e5798857d27ddfbdb4a14890a6460605dcd1d3 Mon Sep 17 00:00:00 2001 From: Robin Edwards Date: Fri, 6 Dec 2019 01:44:51 +0000 Subject: [PATCH] [AIRFLOW-6177] Log DAG processors timeout event at error level, not info (#6731) This case prevents a DAG from being scheduled so should be an error. (cherry picked from commit fb929ebd06f3359b22f683957fead6f949fb9155) --- airflow/utils/dag_processing.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py index dc3f60be5c2504..b904791f2a502a 100644 --- a/airflow/utils/dag_processing.py +++ b/airflow/utils/dag_processing.py @@ -1327,7 +1327,7 @@ def _kill_timed_out_processors(self): for file_path, processor in self._processors.items(): duration = now - processor.start_time if duration > self._processor_timeout: - self.log.info( + self.log.error( "Processor for %s with PID %s started at %s has timed out, " "killing it.", processor.file_path, processor.pid, processor.start_time.isoformat())