add coverage for kind

Author: ohmayr

gapic/templates/tests/unit/gapic/%name_%version/%sub/test_%service.py.j2

@@ -1041,19 +1041,9 @@ def test_transport_adc(transport_class):
         transport_class()
         adc.assert_called_once()
 
-@pytest.mark.parametrize("transport_name", [
-    {% if "grpc" in opts.transport %}
-    "grpc",
-    {% endif %}
-    {% if "rest" in opts.transport %}
-    "rest",
-    {% endif %}
-])
-def test_transport_kind(transport_name):
-    transport = {{ service.client_name }}.get_transport_class(transport_name)(
-        credentials=ga_credentials.AnonymousCredentials(),
-    )
-    assert transport.kind == transport_name
+{{ test_macros.transport_kind_test(service, opts) }}
+
+{{ test_macros.transport_kind_test(service, opts, is_async=True) }}
 
 {% if 'grpc' in opts.transport %}
 def test_transport_grpc_default():

gapic/templates/tests/unit/gapic/%name_%version/%sub/test_macros.j2

@@ -1876,3 +1876,33 @@ def test_{{ method_name }}_empty_call():
         {% endwith %}{# method_settings #}
         assert args[0] == {{ method.input.ident }}()
 {% endmacro %}
+
+
+{% macro transport_kind_test(service, opts, is_async=False) %}
+@pytest.mark.parametrize("transport_name", [
+    {% if is_async %}
+    {% if "grpc" in opts.transport %}
+    "grpc_asyncio",
+    {% endif %}
+    {% else %}{# if not is_async #}
+    {% if "grpc" in opts.transport%}
+    "grpc",
+    {% endif %}
+    {% if "rest" in opts.transport %}
+    "rest",
+    {% endif %}
+    {% endif %}{# is_async #}
+])
+{% if is_async %}
+async def test_transport_kind_async(transport_name):
+    transport = {{ service.async_client_name }}.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+{% else %}
+def test_transport_kind(transport_name):
+    transport = {{ service.client_name }}.get_transport_class(transport_name)(
+        credentials=ga_credentials.AnonymousCredentials(),
+    )
+{% endif %}
+    assert transport.kind == transport_name
+{% endmacro %}

tests/integration/goldens/asset/tests/unit/gapic/asset_v1/test_asset_service.py

@@ -16415,6 +16415,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = AssetServiceAsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = AssetServiceClient(

tests/integration/goldens/credentials/tests/unit/gapic/credentials_v1/test_iam_credentials.py

@@ -3500,6 +3500,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = IAMCredentialsAsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = IAMCredentialsClient(

tests/integration/goldens/eventarc/tests/unit/gapic/eventarc_v1/test_eventarc.py

@@ -13847,6 +13847,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = EventarcAsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = EventarcClient(

tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_config_service_v2.py

@@ -12344,6 +12344,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = ConfigServiceV2AsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = ConfigServiceV2Client(

tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_logging_service_v2.py

@@ -3108,6 +3108,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = LoggingServiceV2AsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = LoggingServiceV2Client(

tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_metrics_service_v2.py

@@ -2915,6 +2915,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = MetricsServiceV2AsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = MetricsServiceV2Client(

tests/integration/goldens/redis/tests/unit/gapic/redis_v1/test_cloud_redis.py

@@ -8413,6 +8413,17 @@ def test_transport_kind(transport_name):
     )
     assert transport.kind == transport_name
 
+
+@pytest.mark.parametrize("transport_name", [
+    "grpc_asyncio",
+])
+async def test_transport_kind_async(transport_name):
+    transport = CloudRedisAsyncClient.get_transport_class(transport_name)(
+        credentials=async_anonymous_credentials(),
+    )
+    assert transport.kind == transport_name
+
+
 def test_transport_grpc_default():
     # A client should use the gRPC transport by default.
     client = CloudRedisClient(