From f2371edafef9aa1f3f05ad8c090011dbf0b6c12a Mon Sep 17 00:00:00 2001 From: William Pursell Date: Wed, 19 Sep 2018 10:42:26 -0700 Subject: [PATCH] [AIRFLOW-3090] Demote dag start/stop log messages to debug --- airflow/utils/dag_processing.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 )