fix logger issue

apache · May 16, 2024 · 6db95e0 · 6db95e0
1 parent 7dca35c
commit 6db95e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)