jason810496 commented on code in PR #63185:
URL: https://github.com/apache/airflow/pull/63185#discussion_r3658165662
##########
airflow-core/src/airflow/dag_processing/manager.py:
##########
@@ -335,7 +335,9 @@ def sync_bundles(self) -> None:
"""Sync configured DAG bundles to the metadata database."""
# When this processor only parses a subset of bundles, it does not see
the full
# bundle configuration and must not deactivate bundles owned by other
processors.
- DagBundlesManager().sync_bundles_to_db(deactivate_missing=not
self.bundle_names_to_parse)
+ dag_bundle_manager = DagBundlesManager()
+ dag_bundle_manager.sync_bundles_to_db(deactivate_missing=not
self.bundle_names_to_parse)
+ dag_bundle_manager.reassign_dags_with_unconfigured_bundles()
Review Comment:
Addressed in
https://github.com/apache/airflow/commit/2472a3260fed8fe2869c91ca60920bcc622c51fc,
with try/except with logging.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
