We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6b18598 commit 4f66981Copy full SHA for 4f66981
airflow/utils/dag_processing.py
@@ -487,7 +487,7 @@ def heartbeat(self):
487
488
for file_path, processor in self._processors.items():
489
if processor.done:
490
- self.log.info("Processor for %s finished", file_path)
+ self.log.debug("Processor for %s finished", file_path)
491
now = timezone.utcnow()
492
finished_processors[file_path] = processor
493
self._last_runtime[file_path] = (now -
@@ -560,7 +560,7 @@ def heartbeat(self):
560
processor = self._processor_factory(file_path)
561
562
processor.start()
563
- self.log.info(
+ self.log.debug(
564
"Started a process (PID: %s) to generate tasks for %s",
565
processor.pid, file_path
566
)
0 commit comments