Move DagBag to airflow/dag_processing #55139
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
ephraimbuddy
requested review from
XD-DENG,
amoghrajesh,
ashb,
bugraoz93,
jason810496,
jedcunningham,
kaxil,
pierrejeambrun,
rawwar and
shubhamraj-git
as code owners
boring-cyborg
bot
added
area:API
ephraimbuddy
force-pushed
the
move-dagbag-to-dag-processing
branch
from
a690dbb to
4689218
Compare
ephraimbuddy
removed
the
backport-to-v3-1-test
ephraimbuddy
force-pushed
the
move-dagbag-to-dag-processing
branch
2 times, most recently
from
fcb54e6 to
7e723c1
Compare
amoghrajesh
reviewed
Sep 2, 2025
Contributor
amoghrajesh
left a comment
amoghrajesh
left a comment
There was a problem hiding this comment.
The change makes sense to me
ephraimbuddy
force-pushed
the
move-dagbag-to-dag-processing
branch
2 times, most recently
from
99391eb to
8486677
Compare
ephraimbuddy
force-pushed
the
move-dagbag-to-dag-processing
branch
from
0fab14c to
4ffaa8d
Compare
ephraimbuddy
commented
Sep 3, 2025
ephraimbuddy
force-pushed
the
move-dagbag-to-dag-processing
branch
from
16f35bf to
9cba1e9
Compare
Contributor
|
I'm just running into this PR now since it causes merge conflicts with one of mine. Should we not move the test module |
Member
|
Yep, it should, good call. |
19 tasks
4 tasks
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Sep 30, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 1, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 2, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 3, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 4, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 5, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 5, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 7, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 8, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 9, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 10, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 11, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 12, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 14, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 15, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 17, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
abdulrahman305 bot
pushed a commit
to abdulrahman305/airflow
that referenced
this pull request
Oct 19, 2025
* Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! Move DagBag to airflow/dag_processing * fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * fixup! fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Move DagBag to airflow/dag_processing DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag", and helps avoid import tangles. What changed: New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db Old location airflow.models.dagbag: Trimmed to DB-facing helpers (DBDagBag, etc.) Adds __getattr__ shim for backward compatibility. Updated imports across the codebase Pre-commit path allowlist updated to include the new file and remove the old path. Deprecation & migration Deprecated: from airflow.models.dagbag import DagBag Use instead: from airflow.dag_processing.dagbag import DagBag A deprecation warning is emitted via the shim; no functional behavior change intended. Notes No runtime logic changes to parsing or DAG discovery. Tests and CLI code updated to the new import path. sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place. * fixup! fixup! fixup! fixup! fixup! fixup! fixup! Move DagBag to airflow/dag_processing * Remove get_dagbag method from DagBundlesManager * Fix dagbag mock * import DagBag from models instead of models.dagbag in providers * fixup! import DagBag from models instead of models.dagbag in providers * fix fab www-hash * fixup! fix fab www-hash * leave DagBag import to be from airflow.models.dagbag in init so it issues deprecation warning * Use DBDagBag in fab type checking if in AF3.1+ * fix static checks * Update fab hash * fixup! Update fab hash * fixup! fixup! Update fab hash * fixup! fixup! fixup! Update fab hash
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
6 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
DagBag is not a DB model, it’s the parser/collector used by the dag processor. This change moves it to a more natural home under airflow/dag_processing, reduces confusion between “DBDagBag” and "DagBag",
and helps avoid import tangles.
What changed:
New module: airflow.dag_processing.dagbag now hosts: DagBag, _capture_with_reraise, FileLoadStat, timeout, sync_bag_to_db
Old location airflow.models.dagbag:
Trimmed to DB-facing helpers (DBDagBag, etc.)
Adds getattr shim for backward compatibility.
Updated imports across the codebase
Pre-commit path allowlist updated to include the new file and remove the old path.
Deprecation & migration
Deprecated: from airflow.models.dagbag import DagBag
Use instead: from airflow.dag_processing.dagbag import DagBag
A deprecation warning is emitted via the shim; no functional behavior change intended.
Notes
No runtime logic changes to parsing or DAG discovery.
Tests and CLI code updated to the new import path.
sync_bag_to_db moved alongside DagBag to keep parsing + persistence in one place.