jason810496 commented on code in PR #70805:
URL: https://github.com/apache/airflow/pull/70805#discussion_r3702522950
##########
airflow-core/src/airflow/dag_processing/bundles/manager.py:
##########
@@ -427,6 +427,11 @@ def get_bundle(
name=name, version=version, version_data=version_data,
**cfg_bundle.kwargs
)
+ @classmethod
+ def is_bundle_configured(cls, name: str) -> bool:
+ """Return whether *name* is a configured Dag bundle, without
constructing the bundle."""
+ return name in cls()._bundle_config
Review Comment:
Actually, the `is_bundle_configured` I imaged should only check the config
level (just to ensure user did setup the corresponding DagBundel without typo)
without importing / initialized any DagBundle. I just refactored the method
again.
--
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]
