use dag_folder for stats

apache · Dec 19, 2024 · ba11246 · ba11246
1 parent 60b04ae
commit ba11246
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py
@@ -580,7 +580,7 @@ def collect_dags(
                 file_parse_end_dttm = timezone.utcnow()
                 stats.append(
                     FileLoadStat(
-                        file=filepath.replace(settings.DAGS_FOLDER, ""),
+                        file=filepath.replace(dag_folder, ""),
                         duration=file_parse_end_dttm - file_parse_start_dttm,
                         dag_num=len(found_dags),
                         task_num=sum(len(dag.tasks) for dag in found_dags),