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

Reply via email to