diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py index 89e5701cf15bf..8ddddad104ac7 100644 --- a/airflow/utils/dag_processing.py +++ b/airflow/utils/dag_processing.py @@ -487,7 +487,7 @@ def heartbeat(self): for file_path, processor in self._processors.items(): if processor.done: - self.log.info("Processor for %s finished", file_path) + self.log.debug("Processor for %s finished", file_path) now = timezone.utcnow() finished_processors[file_path] = processor self._last_runtime[file_path] = (now - @@ -560,7 +560,7 @@ def heartbeat(self): processor = self._processor_factory(file_path) processor.start() - self.log.info( + self.log.debug( "Started a process (PID: %s) to generate tasks for %s", processor.pid, file_path )