(airflow) branch main updated: Reduce Dag processor log noise from per-Dag run lookups (#69452)

[weilee]

This is an automated email from the ASF dual-hosted git repository.

Lee-W pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 821a079fd39 Reduce Dag processor log noise from per-Dag run lookups 
(#69452)
821a079fd39 is described below

commit 821a079fd39e976aefc9358d068db53bc8a99a02
Author: Wei Lee <weilee...@gmail.com>
AuthorDate: Tue Jul 7 12:13:13 2026 +0800

    Reduce Dag processor log noise from per-Dag run lookups (#69452)
---
 airflow-core/src/airflow/dag_processing/collection.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/airflow-core/src/airflow/dag_processing/collection.py 
b/airflow-core/src/airflow/dag_processing/collection.py
index 003a4da016e..9ea66e60ed3 100644
--- a/airflow-core/src/airflow/dag_processing/collection.py
+++ b/airflow-core/src/airflow/dag_processing/collection.py
@@ -194,20 +194,20 @@ class _RunInfo(NamedTuple):
             return cls(None, 0)
 
         if dag.timetable.partitioned:
-            log.info("Getting latest run for partitioned Dag", 
dag_id=dag.dag_id)
+            log.debug("Getting latest run for partitioned Dag", 
dag_id=dag.dag_id)
             latest_run = 
session.scalar(_get_latest_runs_stmt_partitioned(dag_id=dag.dag_id))
         else:
-            log.info("Getting latest run for non-partitioned Dag", 
dag_id=dag.dag_id)
+            log.debug("Getting latest run for non-partitioned Dag", 
dag_id=dag.dag_id)
             latest_run = 
session.scalar(_get_latest_runs_stmt(dag_id=dag.dag_id))
         if latest_run:
-            log.info(
+            log.debug(
                 "got latest run",
                 dag_id=dag.dag_id,
                 logical_date=str(latest_run.logical_date),
                 partition_key=latest_run.partition_key,
             )
         else:
-            log.info("no latest run found", dag_id=dag.dag_id)
+            log.debug("no latest run found", dag_id=dag.dag_id)
         active_run_counts = DagRun.active_runs_of_dags(
             dag_ids=[dag.dag_id],
             exclude_backfill=True,