fixup! Add bundle_name to ParseImportError

ephraimbuddy · ephraimbuddy · commit 5a13ee41a97b · 2025-01-13T21:32:10.000+01:00
diff --git a/airflow/api/common/delete_dag.py b/airflow/api/common/delete_dag.py
@@ -77,7 +77,7 @@ def delete_dag(dag_id: str, keep_records_in_log: bool = True, session: Session =
         delete(ParseImportError)
         .where(
             ParseImportError.filename == dag.fileloc,
-            ParseImportError.bundle_name == dag.get_bundle_name(session),
+            ParseImportError.bundle_name == dag.bundle_name,
         )
         .execution_options(synchronize_session="fetch")
     )

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ def delete_dag(dag_id: str, keep_records_in_log: bool = True, session: Session =`
`77`	`77`	`delete(ParseImportError)`
`78`	`78`	`.where(`
`79`	`79`	`ParseImportError.filename == dag.fileloc,`
`80`		`- ParseImportError.bundle_name == dag.get_bundle_name(session),`
	`80`	`+ ParseImportError.bundle_name == dag.bundle_name,`
`81`	`81`	`)`
`82`	`82`	`.execution_options(synchronize_session="fetch")`
`83`	`83`	`)`