DatastoreHook: Remove datastore_conn_id (#23323)

* `DatastoreHook`: Remove `datastore_conn_id`

Author: eladkal

airflow/providers/google/CHANGELOG.rst

@@ -34,6 +34,8 @@ Breaking changes
    For more information, see `Deprecation and sunset <https://developers.google.com/google-ads/api/docs/sunset-dates>`_
    and `Upgrading to the newest version <https://developers.google.com/google-ads/api/docs/version-migration>`_
 
+* ``DatastoreHook``: Remove ``datastore_conn_id``. Please use ``gcp_conn_id``
+
 * ``CloudBuildCreateBuildOperator``: Remove ``body``. Please use ``build``
 
 * ``BigtableCreateInstanceOperator`` Remove ``replica_cluster_id``, ``replica_cluster_zone``. Please use ``replica_clusters``.

airflow/providers/google/cloud/hooks/datastore.py

@@ -20,7 +20,6 @@
 
 
 import time
-import warnings
 from typing import Any, Dict, Optional, Sequence, Union
 
 from googleapiclient.discovery import Resource, build
@@ -43,17 +42,8 @@ def __init__(
         gcp_conn_id: str = "google_cloud_default",
         delegate_to: Optional[str] = None,
         api_version: str = 'v1',
-        datastore_conn_id: Optional[str] = None,
         impersonation_chain: Optional[Union[str, Sequence[str]]] = None,
     ) -> None:
-        if datastore_conn_id:
-            warnings.warn(
-                "The datastore_conn_id parameter has been deprecated. You should pass "
-                "the gcp_conn_id parameter.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-            gcp_conn_id = datastore_conn_id
         super().__init__(
             gcp_conn_id=gcp_conn_id,
             delegate_to=delegate_to,

airflow/providers/google/cloud/operators/datastore.py

@@ -119,8 +119,8 @@ def execute(self, context: 'Context') -> dict:
                 gcs_hook.delete(self.bucket, obj)
 
         ds_hook = DatastoreHook(
-            self.datastore_conn_id,
-            self.delegate_to,
+            gcp_conn_id=self.datastore_conn_id,
+            delegate_to=self.delegate_to,
             impersonation_chain=self.impersonation_chain,
         )
         result = ds_hook.export_to_storage_bucket(

tests/providers/google/cloud/operators/test_datastore.py

@@ -59,7 +59,7 @@ def test_execute(self, mock_hook):
         )
         op.execute(context={'ti': mock.MagicMock()})
 
-        mock_hook.assert_called_once_with(CONN_ID, None, impersonation_chain=None)
+        mock_hook.assert_called_once_with(gcp_conn_id=CONN_ID, delegate_to=None, impersonation_chain=None)
         mock_hook.return_value.export_to_storage_bucket.assert_called_once_with(
             project_id=PROJECT_ID,
             bucket=BUCKET,