From ad48ff8aa2e0c8fddf7a21d3c9d2ea38e0a52641 Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Fri, 27 Dec 2024 09:44:41 +0100 Subject: [PATCH] Populate the connection form with git type connection --- airflow/dag_processing/bundles/provider.yaml | 5 ++--- airflow/providers_manager.py | 5 +++++ 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/airflow/dag_processing/bundles/provider.yaml b/airflow/dag_processing/bundles/provider.yaml index fcbb81c97e0950..32a2dec28a379b 100644 --- a/airflow/dag_processing/bundles/provider.yaml +++ b/airflow/dag_processing/bundles/provider.yaml @@ -16,10 +16,10 @@ # under the License. --- -package-name: apache-airflow-providers-git +package-name: apache-airflow-providers-bundles name: GIT description: | - `GIT`__ + `GIT `__ state: not-ready source-date-epoch: 1726861127 @@ -30,7 +30,6 @@ versions: dependencies: - apache-airflow-providers-ssh - paramiko>=2.9.0 - - asyncssh>=2.12.0 integrations: - integration-name: GIT (Git) diff --git a/airflow/providers_manager.py b/airflow/providers_manager.py index 8d9f93734d7eb8..e5bf3aece44e7f 100644 --- a/airflow/providers_manager.py +++ b/airflow/providers_manager.py @@ -175,6 +175,9 @@ def _create_customized_form_field_behaviours_schema_validator(): def _check_builtin_provider_prefix(provider_package: str, class_name: str) -> bool: + if "bundles" in provider_package: + # TODO: remove this when this package is moved to providers directory + return True if provider_package.startswith("apache-airflow"): provider_path = provider_package[len("apache-") :].replace("-", ".") if not class_name.startswith(provider_path): @@ -676,6 +679,8 @@ def _discover_all_airflow_builtin_providers_from_local_sources(self) -> None: self._add_provider_info_from_local_source_files_on_path(path) except Exception as e: log.warning("Error when loading 'provider.yaml' files from %s airflow sources: %s", path, e) + # TODO: Remove this when the package is moved to providers + self._add_provider_info_from_local_source_files_on_path("airflow/dag_processing") def _add_provider_info_from_local_source_files_on_path(self, path) -> None: """