feat: add hook-name to connection types

Author: yuseok89

airflow-core/src/airflow/api_fastapi/core_api/services/ui/connections.py

@@ -241,10 +241,10 @@ def hook_meta_data() -> list[ConnectionHookMetaData]:
                 hook_name = raw_entry.hook_name
                 hook_class_name = raw_entry.hook_class_name
             elif provider_entry:
-                hook_name = conn_type
+                hook_name = pm._hook_name_dict.get(conn_type, conn_type)
                 hook_class_name = provider_entry.hook_class_name
             else:
-                hook_name = conn_type
+                hook_name = pm._hook_name_dict.get(conn_type, conn_type)
                 hook_class_name = None
 
             result.append(

airflow-core/src/airflow/provider.yaml.schema.json

@@ -378,6 +378,10 @@
                         "description": "Hook class name that implements the connection type",
                         "type": "string"
                     },
+                    "hook-name": {
+                        "description": "Display name for the connection type in the UI (e.g. 'File (path)', 'Slack')",
+                        "type": "string"
+                    },
                     "ui-field-behaviour": {
                         "description": "Customizations for standard connection form fields",
                         "type": "object",

airflow-core/src/airflow/provider_info.schema.json

@@ -298,6 +298,10 @@
                     "hook-class-name": {
                         "description": "Hook class name that implements the connection type",
                         "type": "string"
+                    },
+                    "hook-name": {
+                        "description": "Display name for the connection type in the UI",
+                        "type": "string"
                     }
                 },
                 "required": [

airflow-core/src/airflow/providers_manager.py

@@ -413,6 +413,8 @@ def __init__(self):
         self._dialect_provider_dict: dict[str, DialectInfo] = {}
         # Keeps dict of hooks keyed by connection type. They are lazy evaluated at access time
         self._hooks_lazy_dict: LazyDictWithCache[str, HookInfo | Callable] = LazyDictWithCache()
+        # Keeps hook display names read from provider.yaml (hook-name field)
+        self._hook_name_dict: dict[str, str] = {}
         # Keeps methods that should be used to add custom widgets tuple of keyed by name of the extra field
         self._connection_form_widgets: dict[str, ConnectionFormWidgetInfo] = {}
         # Customizations for javascript fields are kept here
@@ -996,6 +998,9 @@ def _load_ui_metadata(self) -> None:
                 if not connection_type or not hook_class_name:
                     continue
 
+                if hook_name := conn_config.get("hook-name"):
+                    self._hook_name_dict[connection_type] = hook_name
+
                 if conn_fields := conn_config.get("conn-fields"):
                     self._add_widgets(package_name, hook_class_name, connection_type, conn_fields)
 

providers/airbyte/src/airflow/providers/airbyte/get_provider_info.py

@@ -50,6 +50,7 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.airbyte.hooks.airbyte.AirbyteHook",
+                "hook-name": "Airbyte",
                 "connection-type": "airbyte",
                 "ui-field-behaviour": {
                     "hidden-fields": ["extra", "port"],

providers/alibaba/src/airflow/providers/alibaba/get_provider_info.py

@@ -91,14 +91,17 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.alibaba.cloud.hooks.oss.OSSHook",
+                "hook-name": "OSS",
                 "connection-type": "oss",
             },
             {
                 "hook-class-name": "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook",
+                "hook-name": "AnalyticDB Spark",
                 "connection-type": "adb_spark",
             },
             {
                 "hook-class-name": "airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook",
+                "hook-name": "Alibaba Cloud",
                 "connection-type": "alibaba_cloud",
                 "conn-fields": {
                     "access_key_id": {
@@ -113,6 +116,7 @@ def get_provider_info():
             },
             {
                 "hook-class-name": "airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook",
+                "hook-name": "MaxCompute",
                 "connection-type": "maxcompute",
                 "ui-field-behaviour": {
                     "hidden-fields": ["host", "schema", "login", "password", "port", "extra"],

providers/amazon/src/airflow/providers/amazon/get_provider_info.py

@@ -1084,6 +1084,7 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.amazon.aws.hooks.base_aws.AwsGenericHook",
+                "hook-name": "Amazon Web Services",
                 "connection-type": "aws",
                 "ui-field-behaviour": {
                     "hidden-fields": ["host", "schema", "port"],
@@ -1097,6 +1098,7 @@ def get_provider_info():
             },
             {
                 "hook-class-name": "airflow.providers.amazon.aws.hooks.chime.ChimeWebhookHook",
+                "hook-name": "Amazon Chime Webhook",
                 "connection-type": "chime",
                 "ui-field-behaviour": {
                     "hidden-fields": ["login", "port", "extra"],
@@ -1110,6 +1112,7 @@ def get_provider_info():
             },
             {
                 "hook-class-name": "airflow.providers.amazon.aws.hooks.emr.EmrHook",
+                "hook-name": "Amazon Elastic MapReduce",
                 "connection-type": "emr",
                 "ui-field-behaviour": {
                     "hidden-fields": ["host", "schema", "port", "login", "password"],
@@ -1121,11 +1124,13 @@ def get_provider_info():
             },
             {
                 "hook-class-name": "airflow.providers.amazon.aws.hooks.redshift_sql.RedshiftSQLHook",
+                "hook-name": "Amazon Redshift",
                 "connection-type": "redshift",
                 "ui-field-behaviour": {"relabeling": {"login": "User", "schema": "Database"}},
             },
             {
                 "hook-class-name": "airflow.providers.amazon.aws.hooks.athena_sql.AthenaSQLHook",
+                "hook-name": "Amazon Athena",
                 "connection-type": "athena",
                 "ui-field-behaviour": {
                     "hidden-fields": ["host", "port"],

providers/apache/cassandra/src/airflow/providers/apache/cassandra/get_provider_info.py

@@ -53,6 +53,7 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.apache.cassandra.hooks.cassandra.CassandraHook",
+                "hook-name": "Cassandra",
                 "connection-type": "cassandra",
             }
         ],

providers/apache/drill/src/airflow/providers/apache/drill/get_provider_info.py

@@ -44,6 +44,7 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.apache.drill.hooks.drill.DrillHook",
+                "hook-name": "Drill",
                 "connection-type": "drill",
             }
         ],

providers/apache/druid/src/airflow/providers/apache/druid/get_provider_info.py

@@ -50,6 +50,7 @@ def get_provider_info():
         "connection-types": [
             {
                 "hook-class-name": "airflow.providers.apache.druid.hooks.druid.DruidDbApiHook",
+                "hook-name": "Druid",
                 "connection-type": "druid",
             }
         ],