This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi 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 46472e5fbba Fix depreccated DagBag import from models.dagbag (#58938)
46472e5fbba is described below
commit 46472e5fbbaf170751aed8291cd98fdfe9e79007
Author: Ephraim Anierobi <[email protected]>
AuthorDate: Tue Dec 2 18:58:47 2025 +0100
Fix depreccated DagBag import from models.dagbag (#58938)
* Fix depreccated DagBag import from models.dagbag
DagBag was moved to dag_processing.dagbag so this import in models
init should be updated to fix the deprecation that occurs when we
startup airflow
* add models.dagbag import so we are sure DagPriorityParsingRequest table
are always created
---
airflow-core/src/airflow/models/__init__.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/models/__init__.py
b/airflow-core/src/airflow/models/__init__.py
index c395197a158..231d0f019af 100644
--- a/airflow-core/src/airflow/models/__init__.py
+++ b/airflow-core/src/airflow/models/__init__.py
@@ -64,6 +64,7 @@ def import_all_models():
import airflow.models.backfill
import airflow.models.dag_favorite
import airflow.models.dag_version
+ import airflow.models.dagbag
import airflow.models.dagbundle
import airflow.models.dagwarning
import airflow.models.errors
@@ -99,7 +100,7 @@ __lazy_imports = {
"BaseXCom": "airflow.sdk.bases.xcom",
"Callback": "airflow.models.callback",
"Connection": "airflow.models.connection",
- "DagBag": "airflow.models.dagbag",
+ "DagBag": "airflow.dag_processing.dagbag",
"DagModel": "airflow.models.dag",
"DagRun": "airflow.models.dagrun",
"DagTag": "airflow.models.dag",
@@ -125,11 +126,11 @@ __lazy_imports = {
if TYPE_CHECKING:
# I was unable to get mypy to respect a airflow/models/__init__.pyi, so
# having to resort back to this hacky method
+ from airflow.dag_processing.dagbag import DagBag
from airflow.models.base import ID_LEN, Base
from airflow.models.callback import Callback
from airflow.models.connection import Connection
from airflow.models.dag import DagModel, DagTag
- from airflow.models.dagbag import DagBag
from airflow.models.dagrun import DagRun
from airflow.models.dagwarning import DagWarning
from airflow.models.db_callback_request import DbCallbackRequest