diff --git a/airflow/datasets/manager.py b/airflow/datasets/manager.py
index 05492f2797c0f..d3e7a8cf84bf2 100644
--- a/airflow/datasets/manager.py
+++ b/airflow/datasets/manager.py
@@ -146,7 +146,7 @@ def _queue_dagrun_if_needed(dag: DagModel) -> str | None:
                 with session.begin_nested():
                     session.merge(item)
             except exc.IntegrityError:
-                cls.logger().log.debug("Skipping record %s", item, exc_info=True)
+                cls.logger().debug("Skipping record %s", item, exc_info=True)
             return dag.dag_id
 
         queued_results = (_queue_dagrun_if_needed(ref.dag) for ref in dataset.consuming_dags)