chore: use gapic-generator-python 0.62.1 (#5)

- [ ] Regenerate this pull request now. committer: parthea PiperOrigin-RevId: 425964861 Source-Link: googleapis/googleapis@84b1a5a Source-Link: googleapis/googleapis-gen@4fb761b Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNGZiNzYxYmJkODUwNmFjMTU2ZjQ5YmFjNWYxODMwNmFhOGViM2FhOCJ9
googleapis · Feb 4, 2022 · b60a9ae · b60a9ae
1 parent 0b6e43a
commit b60a9ae
Show file tree

Hide file tree

Showing 5 changed files with 134 additions and 105 deletions.
diff --git a/packages/google-cloud-dataplex/.github/workflows/unittest.yml b/packages/google-cloud-dataplex/.github/workflows/unittest.yml
@@ -54,4 +54,4 @@ jobs:
     - name: Report coverage results
       run: |
         coverage combine .coverage-results/.coverage*
-        coverage report --show-missing --fail-under=99
+        coverage report --show-missing --fail-under=100
diff --git a/packages/google-cloud-dataplex/noxfile.py b/packages/google-cloud-dataplex/noxfile.py
@@ -175,7 +175,7 @@ def cover(session):
     test runs (not system test runs), and then erases coverage data.
     """
     session.install("coverage", "pytest-cov")
-    session.run("coverage", "report", "--show-missing", "--fail-under=99")
+    session.run("coverage", "report", "--show-missing", "--fail-under=100")
 
     session.run("coverage", "erase")
 

diff --git a/packages/google-cloud-dataplex/owlbot.py b/packages/google-cloud-dataplex/owlbot.py
diff --git a/packages/google-cloud-dataplex/tests/unit/gapic/dataplex_v1/test_dataplex_service.py b/packages/google-cloud-dataplex/tests/unit/gapic/dataplex_v1/test_dataplex_service.py
@@ -566,35 +566,6 @@ def test_dataplex_service_client_client_options_credentials_file(
             always_use_jwt_access=True,
         )
 
-    if "grpc" in transport_name:
-        # test that the credentials from file are saved and used as the credentials.
-        with mock.patch.object(
-            google.auth, "load_credentials_from_file", autospec=True
-        ) as load_creds, mock.patch.object(
-            google.auth, "default", autospec=True
-        ) as adc, mock.patch.object(
-            grpc_helpers, "create_channel"
-        ) as create_channel:
-            creds = ga_credentials.AnonymousCredentials()
-            file_creds = ga_credentials.AnonymousCredentials()
-            load_creds.return_value = (file_creds, None)
-            adc.return_value = (creds, None)
-            client = client_class(client_options=options, transport=transport_name)
-            create_channel.assert_called_with(
-                "dataplex.googleapis.com:443",
-                credentials=file_creds,
-                credentials_file=None,
-                quota_project_id=None,
-                default_scopes=("https://www.googleapis.com/auth/cloud-platform",),
-                scopes=None,
-                default_host="dataplex.googleapis.com",
-                ssl_credentials=None,
-                options=[
-                    ("grpc.max_send_message_length", -1),
-                    ("grpc.max_receive_message_length", -1),
-                ],
-            )
-
 
 def test_dataplex_service_client_client_options_from_dict():
     with mock.patch(
@@ -616,6 +587,72 @@ def test_dataplex_service_client_client_options_from_dict():
         )
 
 
+@pytest.mark.parametrize(
+    "client_class,transport_class,transport_name,grpc_helpers",
+    [
+        (
+            DataplexServiceClient,
+            transports.DataplexServiceGrpcTransport,
+            "grpc",
+            grpc_helpers,
+        ),
+        (
+            DataplexServiceAsyncClient,
+            transports.DataplexServiceGrpcAsyncIOTransport,
+            "grpc_asyncio",
+            grpc_helpers_async,
+        ),
+    ],
+)
+def test_dataplex_service_client_create_channel_credentials_file(
+    client_class, transport_class, transport_name, grpc_helpers
+):
+    # Check the case credentials file is provided.
+    options = client_options.ClientOptions(credentials_file="credentials.json")
+
+    with mock.patch.object(transport_class, "__init__") as patched:
+        patched.return_value = None
+        client = client_class(client_options=options, transport=transport_name)
+        patched.assert_called_once_with(
+            credentials=None,
+            credentials_file="credentials.json",
+            host=client.DEFAULT_ENDPOINT,
+            scopes=None,
+            client_cert_source_for_mtls=None,
+            quota_project_id=None,
+            client_info=transports.base.DEFAULT_CLIENT_INFO,
+            always_use_jwt_access=True,
+        )
+
+    # test that the credentials from file are saved and used as the credentials.
+    with mock.patch.object(
+        google.auth, "load_credentials_from_file", autospec=True
+    ) as load_creds, mock.patch.object(
+        google.auth, "default", autospec=True
+    ) as adc, mock.patch.object(
+        grpc_helpers, "create_channel"
+    ) as create_channel:
+        creds = ga_credentials.AnonymousCredentials()
+        file_creds = ga_credentials.AnonymousCredentials()
+        load_creds.return_value = (file_creds, None)
+        adc.return_value = (creds, None)
+        client = client_class(client_options=options, transport=transport_name)
+        create_channel.assert_called_with(
+            "dataplex.googleapis.com:443",
+            credentials=file_creds,
+            credentials_file=None,
+            quota_project_id=None,
+            default_scopes=("https://www.googleapis.com/auth/cloud-platform",),
+            scopes=None,
+            default_host="dataplex.googleapis.com",
+            ssl_credentials=None,
+            options=[
+                ("grpc.max_send_message_length", -1),
+                ("grpc.max_receive_message_length", -1),
+            ],
+        )
+
+
 @pytest.mark.parametrize("request_type", [service.CreateLakeRequest, dict,])
 def test_create_lake(request_type, transport: str = "grpc"):
     client = DataplexServiceClient(

diff --git a/packages/google-cloud-dataplex/tests/unit/gapic/dataplex_v1/test_metadata_service.py b/packages/google-cloud-dataplex/tests/unit/gapic/dataplex_v1/test_metadata_service.py
@@ -557,35 +557,6 @@ def test_metadata_service_client_client_options_credentials_file(
             always_use_jwt_access=True,
         )
 
-    if "grpc" in transport_name:
-        # test that the credentials from file are saved and used as the credentials.
-        with mock.patch.object(
-            google.auth, "load_credentials_from_file", autospec=True
-        ) as load_creds, mock.patch.object(
-            google.auth, "default", autospec=True
-        ) as adc, mock.patch.object(
-            grpc_helpers, "create_channel"
-        ) as create_channel:
-            creds = ga_credentials.AnonymousCredentials()
-            file_creds = ga_credentials.AnonymousCredentials()
-            load_creds.return_value = (file_creds, None)
-            adc.return_value = (creds, None)
-            client = client_class(client_options=options, transport=transport_name)
-            create_channel.assert_called_with(
-                "dataplex.googleapis.com:443",
-                credentials=file_creds,
-                credentials_file=None,
-                quota_project_id=None,
-                default_scopes=("https://www.googleapis.com/auth/cloud-platform",),
-                scopes=None,
-                default_host="dataplex.googleapis.com",
-                ssl_credentials=None,
-                options=[
-                    ("grpc.max_send_message_length", -1),
-                    ("grpc.max_receive_message_length", -1),
-                ],
-            )
-
 
 def test_metadata_service_client_client_options_from_dict():
     with mock.patch(
@@ -607,6 +578,72 @@ def test_metadata_service_client_client_options_from_dict():
         )
 
 
+@pytest.mark.parametrize(
+    "client_class,transport_class,transport_name,grpc_helpers",
+    [
+        (
+            MetadataServiceClient,
+            transports.MetadataServiceGrpcTransport,
+            "grpc",
+            grpc_helpers,
+        ),
+        (
+            MetadataServiceAsyncClient,
+            transports.MetadataServiceGrpcAsyncIOTransport,
+            "grpc_asyncio",
+            grpc_helpers_async,
+        ),
+    ],
+)
+def test_metadata_service_client_create_channel_credentials_file(
+    client_class, transport_class, transport_name, grpc_helpers
+):
+    # Check the case credentials file is provided.
+    options = client_options.ClientOptions(credentials_file="credentials.json")
+
+    with mock.patch.object(transport_class, "__init__") as patched:
+        patched.return_value = None
+        client = client_class(client_options=options, transport=transport_name)
+        patched.assert_called_once_with(
+            credentials=None,
+            credentials_file="credentials.json",
+            host=client.DEFAULT_ENDPOINT,
+            scopes=None,
+            client_cert_source_for_mtls=None,
+            quota_project_id=None,
+            client_info=transports.base.DEFAULT_CLIENT_INFO,
+            always_use_jwt_access=True,
+        )
+
+    # test that the credentials from file are saved and used as the credentials.
+    with mock.patch.object(
+        google.auth, "load_credentials_from_file", autospec=True
+    ) as load_creds, mock.patch.object(
+        google.auth, "default", autospec=True
+    ) as adc, mock.patch.object(
+        grpc_helpers, "create_channel"
+    ) as create_channel:
+        creds = ga_credentials.AnonymousCredentials()
+        file_creds = ga_credentials.AnonymousCredentials()
+        load_creds.return_value = (file_creds, None)
+        adc.return_value = (creds, None)
+        client = client_class(client_options=options, transport=transport_name)
+        create_channel.assert_called_with(
+            "dataplex.googleapis.com:443",
+            credentials=file_creds,
+            credentials_file=None,
+            quota_project_id=None,
+            default_scopes=("https://www.googleapis.com/auth/cloud-platform",),
+            scopes=None,
+            default_host="dataplex.googleapis.com",
+            ssl_credentials=None,
+            options=[
+                ("grpc.max_send_message_length", -1),
+                ("grpc.max_receive_message_length", -1),
+            ],
+        )
+
+
 @pytest.mark.parametrize("request_type", [metadata_.GetEntityRequest, dict,])
 def test_get_entity(request_type, transport: str = "grpc"):
     client = MetadataServiceClient(