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())