This is an automated email from the ASF dual-hosted git repository.
turaga 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 a46ab402658 Fix edge3 executor startup crash on Airflow < 3.2 (#62593)
a46ab402658 is described below
commit a46ab402658a42a4bb125f428de651c7b4e2573a
Author: Dheeraj Turaga <[email protected]>
AuthorDate: Fri Feb 27 16:50:13 2026 -0600
Fix edge3 executor startup crash on Airflow < 3.2 (#62593)
db_managers was introduced in ProvidersManager in Airflow 3.2, so loading
the edge executor on older versions raised an AttributeError. Guard the access
with hasattr so the executor starts cleanly on all supported versions.
---
providers/edge3/src/airflow/providers/edge3/models/db.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/providers/edge3/src/airflow/providers/edge3/models/db.py
b/providers/edge3/src/airflow/providers/edge3/models/db.py
index 3ff3dd84325..1c98cb40235 100644
--- a/providers/edge3/src/airflow/providers/edge3/models/db.py
+++ b/providers/edge3/src/airflow/providers/edge3/models/db.py
@@ -84,8 +84,10 @@ def check_db_manager_config() -> None:
# Check explicitly configured managers
configured = conf.get("database", "external_db_managers", fallback="")
registered = {m.strip() for m in configured.split(",") if m.strip()}
- # Also check auto-discovered managers from installed providers
- registered |= set(ProvidersManager().db_managers)
+ # Also check auto-discovered managers from installed providers
(db_managers added in Airflow 3.2)
+ pm = ProvidersManager()
+ if hasattr(pm, "db_managers"):
+ registered |= set(pm.db_managers)
if fqcn not in registered:
warnings.warn(
