jscheffl commented on code in PR #60752:
URL: https://github.com/apache/airflow/pull/60752#discussion_r2724650021
##########
airflow-core/src/airflow/utils/db_manager.py:
##########
@@ -179,6 +180,20 @@ def __init__(self):
auth_manager_db_manager = create_auth_manager().get_db_manager()
if auth_manager_db_manager and auth_manager_db_manager not in managers:
managers.append(auth_manager_db_manager)
+ # Add DB managers specified by configured executors (if any)
+ try:
+ executor_names =
ExecutorLoader.get_executor_names(validate_teams=False)
+ for executor_name in executor_names:
+ try:
+ executor_cls, _ =
ExecutorLoader.import_executor_cls(executor_name)
+ if hasattr(executor_cls, "get_db_manager"):
+ executor_db_manager = executor_cls.get_db_manager()
+ if executor_db_manager and executor_db_manager not in
managers:
+ managers.append(executor_db_manager)
+ except Exception:
+ self.log.debug("Could not load DB manager from executor
%s", executor_name)
+ except Exception:
+ self.log.debug("Could not load executor DB managers")
Review Comment:
Would propose to put it to warning level
```suggestion
self.log.warning("Could not load DB manager from
executor %s", executor_name)
except Exception:
self.log.warning("Could not load executor DB managers")
```
--
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]
