diff --git a/packages/gapic-generator/gapic/templates/tests/unit/gapic/%name_%version/%sub/test_macros.j2 b/packages/gapic-generator/gapic/templates/tests/unit/gapic/%name_%version/%sub/test_macros.j2 index 648f2e868812..a612b9397f65 100644 --- a/packages/gapic-generator/gapic/templates/tests/unit/gapic/%name_%version/%sub/test_macros.j2 +++ b/packages/gapic-generator/gapic/templates/tests/unit/gapic/%name_%version/%sub/test_macros.j2 @@ -4,7 +4,9 @@ {%- set auto_populated_field_sample_value = "explicit value for autopopulate-able field" -%} {% with method_name = method.client_method_name|snake_case + "_unary" if method.extended_lro and not full_extended_lro else method.client_method_name|snake_case, method_output = method.extended_lro.operation_type if method.extended_lro and not full_extended_lro else method.output %} @pytest.mark.parametrize("request_type", [ - {{ method.input.ident }}({ +{% if auto_populated_fields %} + # Pure protobuf messages (non-proto-plus) require keyword arguments. + {{ method.input.ident }}(**{ {% for auto_populated_field in auto_populated_fields %} "{{ auto_populated_field }}": "{{ auto_populated_field_sample_value }}", {% endfor %} @@ -14,6 +16,10 @@ "{{ auto_populated_field }}": "{{ auto_populated_field_sample_value }}", {% endfor %} }, +{% else %} + {{ method.input.ident }}(), + {}, +{% endif %} ]) def test_{{ method_name }}(request_type, transport: str = 'grpc'): client = {{ service.client_name }}( @@ -260,7 +266,9 @@ async def test_{{ method_name }}_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - {{ method.input.ident }}({ +{% if auto_populated_fields %} + # Pure protobuf messages (non-proto-plus) require keyword arguments. + {{ method.input.ident }}(**{ {%- for auto_populated_field in auto_populated_fields %} "{{ auto_populated_field }}": "{{ auto_populated_field_sample_value }}", {%- endfor %} @@ -270,6 +278,10 @@ async def test_{{ method_name }}_async_use_cached_wrapped_rpc(transport: str = " "{{ auto_populated_field }}": "{{ auto_populated_field_sample_value }}", {%- endfor %} }, +{% else %} + {{ method.input.ident }}(), + {}, +{% endif %} ]) async def test_{{ method_name }}_async(request_type, transport: str = 'grpc_asyncio'): client = {{ service.async_client_name }}( diff --git a/packages/gapic-generator/tests/fragments/google/cloud/location/locations.proto b/packages/gapic-generator/tests/fragments/google/cloud/location/locations.proto new file mode 100644 index 000000000000..36a0b0e89ddc --- /dev/null +++ b/packages/gapic-generator/tests/fragments/google/cloud/location/locations.proto @@ -0,0 +1,108 @@ +// Copyright 2025 Google LLC +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +syntax = "proto3"; + +package google.cloud.location; + +import "google/api/annotations.proto"; +import "google/protobuf/any.proto"; +import "google/api/client.proto"; + +option cc_enable_arenas = true; +option go_package = "google.golang.org/genproto/googleapis/cloud/location;location"; +option java_multiple_files = true; +option java_outer_classname = "LocationsProto"; +option java_package = "com.google.cloud.location"; + +// An abstract interface that provides location-related information for +// a service. Service-specific metadata is provided through the +// [Location.metadata][google.cloud.location.Location.metadata] field. +service Locations { + option (google.api.default_host) = "cloud.googleapis.com"; + option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform"; + + // Lists information about the supported locations for this service. + rpc ListLocations(ListLocationsRequest) returns (ListLocationsResponse) { + option (google.api.http) = { + get: "/v1/{name=locations}" + additional_bindings { + get: "/v1/{name=projects/*}/locations" + } + }; + } + + // Gets information about a location. + rpc GetLocation(GetLocationRequest) returns (Location) { + option (google.api.http) = { + get: "/v1/{name=locations/*}" + additional_bindings { + get: "/v1/{name=projects/*/locations/*}" + } + }; + } +} + +// The request message for [Locations.ListLocations][google.cloud.location.Locations.ListLocations]. +message ListLocationsRequest { + // The resource that owns the locations collection, if applicable. + string name = 1; + + // The standard list filter. + string filter = 2; + + // The standard list page size. + int32 page_size = 3; + + // The standard list page token. + string page_token = 4; +} + +// The response message for [Locations.ListLocations][google.cloud.location.Locations.ListLocations]. +message ListLocationsResponse { + // A list of locations that matches the specified filter in the request. + repeated Location locations = 1; + + // The standard List next-page token. + string next_page_token = 2; +} + +// The request message for [Locations.GetLocation][google.cloud.location.Locations.GetLocation]. +message GetLocationRequest { + // Resource name for the location. + string name = 1; +} + +// A resource that represents Google Cloud Platform location. +message Location { + // Resource name for the location, which may vary between implementations. + // For example: `"projects/example-project/locations/us-east1"` + string name = 1; + + // The canonical id for this location. For example: `"us-east1"`. + string location_id = 4; + + // The friendly name for this location, typically a nearby city name. + // For example, "Tokyo". + string display_name = 5; + + // Cross-service attributes for the location. For example + // + // {"cloud.googleapis.com/region": "us-east1"} + map labels = 2; + + // Service-specific metadata. For example the available capacity at the given + // location. + google.protobuf.Any metadata = 3; +} diff --git a/packages/gapic-generator/tests/fragments/test_protobuf_type.proto b/packages/gapic-generator/tests/fragments/test_protobuf_type.proto new file mode 100644 index 000000000000..3f0bb1157b8c --- /dev/null +++ b/packages/gapic-generator/tests/fragments/test_protobuf_type.proto @@ -0,0 +1,28 @@ +// Copyright 2026 Google LLC +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +syntax = "proto3"; + +package google.fragment; + +import "google/api/client.proto"; +import "google/cloud/location/locations.proto"; + +service MockLocationService { + option (google.api.default_host) = "locations.example.com"; + + rpc GetLocation(google.cloud.location.GetLocationRequest) returns (google.cloud.location.Location) { + option (google.api.method_signature) = "name"; + } +} diff --git a/packages/gapic-generator/tests/integration/goldens/asset/tests/unit/gapic/asset_v1/test_asset_service.py b/packages/gapic-generator/tests/integration/goldens/asset/tests/unit/gapic/asset_v1/test_asset_service.py index 5b742aba935a..b6bbf1cdc830 100755 --- a/packages/gapic-generator/tests/integration/goldens/asset/tests/unit/gapic/asset_v1/test_asset_service.py +++ b/packages/gapic-generator/tests/integration/goldens/asset/tests/unit/gapic/asset_v1/test_asset_service.py @@ -981,10 +981,8 @@ def test_asset_service_client_create_channel_credentials_file(client_class, tran @pytest.mark.parametrize("request_type", [ - asset_service.ExportAssetsRequest({ - }), - { - }, + asset_service.ExportAssetsRequest(), + {}, ]) def test_export_assets(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -1120,8 +1118,8 @@ async def test_export_assets_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.ExportAssetsRequest({ }), - { }, + asset_service.ExportAssetsRequest(), + {}, ]) async def test_export_assets_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -1216,10 +1214,8 @@ async def test_export_assets_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.ListAssetsRequest({ - }), - { - }, + asset_service.ListAssetsRequest(), + {}, ]) def test_list_assets(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -1350,8 +1346,8 @@ async def test_list_assets_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.ListAssetsRequest({ }), - { }, + asset_service.ListAssetsRequest(), + {}, ]) async def test_list_assets_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -1723,10 +1719,8 @@ async def test_list_assets_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.BatchGetAssetsHistoryRequest({ - }), - { - }, + asset_service.BatchGetAssetsHistoryRequest(), + {}, ]) def test_batch_get_assets_history(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -1853,8 +1847,8 @@ async def test_batch_get_assets_history_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.BatchGetAssetsHistoryRequest({ }), - { }, + asset_service.BatchGetAssetsHistoryRequest(), + {}, ]) async def test_batch_get_assets_history_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -1948,10 +1942,8 @@ async def test_batch_get_assets_history_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.CreateFeedRequest({ - }), - { - }, + asset_service.CreateFeedRequest(), + {}, ]) def test_create_feed(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -2090,8 +2082,8 @@ async def test_create_feed_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.CreateFeedRequest({ }), - { }, + asset_service.CreateFeedRequest(), + {}, ]) async def test_create_feed_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -2277,10 +2269,8 @@ async def test_create_feed_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.GetFeedRequest({ - }), - { - }, + asset_service.GetFeedRequest(), + {}, ]) def test_get_feed(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -2417,8 +2407,8 @@ async def test_get_feed_async_use_cached_wrapped_rpc(transport: str = "grpc_asyn @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.GetFeedRequest({ }), - { }, + asset_service.GetFeedRequest(), + {}, ]) async def test_get_feed_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -2604,10 +2594,8 @@ async def test_get_feed_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.ListFeedsRequest({ - }), - { - }, + asset_service.ListFeedsRequest(), + {}, ]) def test_list_feeds(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -2734,8 +2722,8 @@ async def test_list_feeds_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.ListFeedsRequest({ }), - { }, + asset_service.ListFeedsRequest(), + {}, ]) async def test_list_feeds_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -2911,10 +2899,8 @@ async def test_list_feeds_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.UpdateFeedRequest({ - }), - { - }, + asset_service.UpdateFeedRequest(), + {}, ]) def test_update_feed(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -3049,8 +3035,8 @@ async def test_update_feed_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.UpdateFeedRequest({ }), - { }, + asset_service.UpdateFeedRequest(), + {}, ]) async def test_update_feed_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -3236,10 +3222,8 @@ async def test_update_feed_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.DeleteFeedRequest({ - }), - { - }, + asset_service.DeleteFeedRequest(), + {}, ]) def test_delete_feed(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -3365,8 +3349,8 @@ async def test_delete_feed_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.DeleteFeedRequest({ }), - { }, + asset_service.DeleteFeedRequest(), + {}, ]) async def test_delete_feed_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -3541,10 +3525,8 @@ async def test_delete_feed_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.SearchAllResourcesRequest({ - }), - { - }, + asset_service.SearchAllResourcesRequest(), + {}, ]) def test_search_all_resources(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -3679,8 +3661,8 @@ async def test_search_all_resources_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.SearchAllResourcesRequest({ }), - { }, + asset_service.SearchAllResourcesRequest(), + {}, ]) async def test_search_all_resources_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -4072,10 +4054,8 @@ async def test_search_all_resources_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.SearchAllIamPoliciesRequest({ - }), - { - }, + asset_service.SearchAllIamPoliciesRequest(), + {}, ]) def test_search_all_iam_policies(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -4210,8 +4190,8 @@ async def test_search_all_iam_policies_async_use_cached_wrapped_rpc(transport: s @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.SearchAllIamPoliciesRequest({ }), - { }, + asset_service.SearchAllIamPoliciesRequest(), + {}, ]) async def test_search_all_iam_policies_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -4593,10 +4573,8 @@ async def test_search_all_iam_policies_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeIamPolicyRequest({ - }), - { - }, + asset_service.AnalyzeIamPolicyRequest(), + {}, ]) def test_analyze_iam_policy(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -4725,8 +4703,8 @@ async def test_analyze_iam_policy_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeIamPolicyRequest({ }), - { }, + asset_service.AnalyzeIamPolicyRequest(), + {}, ]) async def test_analyze_iam_policy_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -4822,10 +4800,8 @@ async def test_analyze_iam_policy_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeIamPolicyLongrunningRequest({ - }), - { - }, + asset_service.AnalyzeIamPolicyLongrunningRequest(), + {}, ]) def test_analyze_iam_policy_longrunning(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -4961,8 +4937,8 @@ async def test_analyze_iam_policy_longrunning_async_use_cached_wrapped_rpc(trans @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeIamPolicyLongrunningRequest({ }), - { }, + asset_service.AnalyzeIamPolicyLongrunningRequest(), + {}, ]) async def test_analyze_iam_policy_longrunning_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -5057,10 +5033,8 @@ async def test_analyze_iam_policy_longrunning_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeMoveRequest({ - }), - { - }, + asset_service.AnalyzeMoveRequest(), + {}, ]) def test_analyze_move(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -5189,8 +5163,8 @@ async def test_analyze_move_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeMoveRequest({ }), - { }, + asset_service.AnalyzeMoveRequest(), + {}, ]) async def test_analyze_move_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -5284,10 +5258,8 @@ async def test_analyze_move_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.QueryAssetsRequest({ - }), - { - }, + asset_service.QueryAssetsRequest(), + {}, ]) def test_query_assets(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -5424,8 +5396,8 @@ async def test_query_assets_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.QueryAssetsRequest({ }), - { }, + asset_service.QueryAssetsRequest(), + {}, ]) async def test_query_assets_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -5523,10 +5495,8 @@ async def test_query_assets_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.CreateSavedQueryRequest({ - }), - { - }, + asset_service.CreateSavedQueryRequest(), + {}, ]) def test_create_saved_query(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -5663,8 +5633,8 @@ async def test_create_saved_query_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.CreateSavedQueryRequest({ }), - { }, + asset_service.CreateSavedQueryRequest(), + {}, ]) async def test_create_saved_query_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -5868,10 +5838,8 @@ async def test_create_saved_query_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.GetSavedQueryRequest({ - }), - { - }, + asset_service.GetSavedQueryRequest(), + {}, ]) def test_get_saved_query(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -6006,8 +5974,8 @@ async def test_get_saved_query_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.GetSavedQueryRequest({ }), - { }, + asset_service.GetSavedQueryRequest(), + {}, ]) async def test_get_saved_query_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -6191,10 +6159,8 @@ async def test_get_saved_query_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.ListSavedQueriesRequest({ - }), - { - }, + asset_service.ListSavedQueriesRequest(), + {}, ]) def test_list_saved_queries(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -6327,8 +6293,8 @@ async def test_list_saved_queries_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.ListSavedQueriesRequest({ }), - { }, + asset_service.ListSavedQueriesRequest(), + {}, ]) async def test_list_saved_queries_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -6700,10 +6666,8 @@ async def test_list_saved_queries_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.UpdateSavedQueryRequest({ - }), - { - }, + asset_service.UpdateSavedQueryRequest(), + {}, ]) def test_update_saved_query(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -6836,8 +6800,8 @@ async def test_update_saved_query_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.UpdateSavedQueryRequest({ }), - { }, + asset_service.UpdateSavedQueryRequest(), + {}, ]) async def test_update_saved_query_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -7031,10 +6995,8 @@ async def test_update_saved_query_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.DeleteSavedQueryRequest({ - }), - { - }, + asset_service.DeleteSavedQueryRequest(), + {}, ]) def test_delete_saved_query(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -7160,8 +7122,8 @@ async def test_delete_saved_query_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.DeleteSavedQueryRequest({ }), - { }, + asset_service.DeleteSavedQueryRequest(), + {}, ]) async def test_delete_saved_query_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -7336,10 +7298,8 @@ async def test_delete_saved_query_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - asset_service.BatchGetEffectiveIamPoliciesRequest({ - }), - { - }, + asset_service.BatchGetEffectiveIamPoliciesRequest(), + {}, ]) def test_batch_get_effective_iam_policies(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -7466,8 +7426,8 @@ async def test_batch_get_effective_iam_policies_async_use_cached_wrapped_rpc(tra @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.BatchGetEffectiveIamPoliciesRequest({ }), - { }, + asset_service.BatchGetEffectiveIamPoliciesRequest(), + {}, ]) async def test_batch_get_effective_iam_policies_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -7561,10 +7521,8 @@ async def test_batch_get_effective_iam_policies_field_headers_async(): @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPoliciesRequest({ - }), - { - }, + asset_service.AnalyzeOrgPoliciesRequest(), + {}, ]) def test_analyze_org_policies(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -7699,8 +7657,8 @@ async def test_analyze_org_policies_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPoliciesRequest({ }), - { }, + asset_service.AnalyzeOrgPoliciesRequest(), + {}, ]) async def test_analyze_org_policies_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -8092,10 +8050,8 @@ async def test_analyze_org_policies_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPolicyGovernedContainersRequest({ - }), - { - }, + asset_service.AnalyzeOrgPolicyGovernedContainersRequest(), + {}, ]) def test_analyze_org_policy_governed_containers(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -8230,8 +8186,8 @@ async def test_analyze_org_policy_governed_containers_async_use_cached_wrapped_r @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPolicyGovernedContainersRequest({ }), - { }, + asset_service.AnalyzeOrgPolicyGovernedContainersRequest(), + {}, ]) async def test_analyze_org_policy_governed_containers_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( @@ -8623,10 +8579,8 @@ async def test_analyze_org_policy_governed_containers_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPolicyGovernedAssetsRequest({ - }), - { - }, + asset_service.AnalyzeOrgPolicyGovernedAssetsRequest(), + {}, ]) def test_analyze_org_policy_governed_assets(request_type, transport: str = 'grpc'): client = AssetServiceClient( @@ -8761,8 +8715,8 @@ async def test_analyze_org_policy_governed_assets_async_use_cached_wrapped_rpc(t @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - asset_service.AnalyzeOrgPolicyGovernedAssetsRequest({ }), - { }, + asset_service.AnalyzeOrgPolicyGovernedAssetsRequest(), + {}, ]) async def test_analyze_org_policy_governed_assets_async(request_type, transport: str = 'grpc_asyncio'): client = AssetServiceAsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/credentials/tests/unit/gapic/credentials_v1/test_iam_credentials.py b/packages/gapic-generator/tests/integration/goldens/credentials/tests/unit/gapic/credentials_v1/test_iam_credentials.py index 6cf5dca6bfb0..14a6074a40f9 100755 --- a/packages/gapic-generator/tests/integration/goldens/credentials/tests/unit/gapic/credentials_v1/test_iam_credentials.py +++ b/packages/gapic-generator/tests/integration/goldens/credentials/tests/unit/gapic/credentials_v1/test_iam_credentials.py @@ -971,10 +971,8 @@ def test_iam_credentials_client_create_channel_credentials_file(client_class, tr @pytest.mark.parametrize("request_type", [ - common.GenerateAccessTokenRequest({ - }), - { - }, + common.GenerateAccessTokenRequest(), + {}, ]) def test_generate_access_token(request_type, transport: str = 'grpc'): client = IAMCredentialsClient( @@ -1103,8 +1101,8 @@ async def test_generate_access_token_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - common.GenerateAccessTokenRequest({ }), - { }, + common.GenerateAccessTokenRequest(), + {}, ]) async def test_generate_access_token_async(request_type, transport: str = 'grpc_asyncio'): client = IAMCredentialsAsyncClient( @@ -1308,10 +1306,8 @@ async def test_generate_access_token_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - common.GenerateIdTokenRequest({ - }), - { - }, + common.GenerateIdTokenRequest(), + {}, ]) def test_generate_id_token(request_type, transport: str = 'grpc'): client = IAMCredentialsClient( @@ -1442,8 +1438,8 @@ async def test_generate_id_token_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - common.GenerateIdTokenRequest({ }), - { }, + common.GenerateIdTokenRequest(), + {}, ]) async def test_generate_id_token_async(request_type, transport: str = 'grpc_asyncio'): client = IAMCredentialsAsyncClient( @@ -1651,10 +1647,8 @@ async def test_generate_id_token_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - common.SignBlobRequest({ - }), - { - }, + common.SignBlobRequest(), + {}, ]) def test_sign_blob(request_type, transport: str = 'grpc'): client = IAMCredentialsClient( @@ -1785,8 +1779,8 @@ async def test_sign_blob_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - common.SignBlobRequest({ }), - { }, + common.SignBlobRequest(), + {}, ]) async def test_sign_blob_async(request_type, transport: str = 'grpc_asyncio'): client = IAMCredentialsAsyncClient( @@ -1986,10 +1980,8 @@ async def test_sign_blob_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - common.SignJwtRequest({ - }), - { - }, + common.SignJwtRequest(), + {}, ]) def test_sign_jwt(request_type, transport: str = 'grpc'): client = IAMCredentialsClient( @@ -2122,8 +2114,8 @@ async def test_sign_jwt_async_use_cached_wrapped_rpc(transport: str = "grpc_asyn @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - common.SignJwtRequest({ }), - { }, + common.SignJwtRequest(), + {}, ]) async def test_sign_jwt_async(request_type, transport: str = 'grpc_asyncio'): client = IAMCredentialsAsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/eventarc/tests/unit/gapic/eventarc_v1/test_eventarc.py b/packages/gapic-generator/tests/integration/goldens/eventarc/tests/unit/gapic/eventarc_v1/test_eventarc.py index c39b30af0310..538dd2b2bac4 100755 --- a/packages/gapic-generator/tests/integration/goldens/eventarc/tests/unit/gapic/eventarc_v1/test_eventarc.py +++ b/packages/gapic-generator/tests/integration/goldens/eventarc/tests/unit/gapic/eventarc_v1/test_eventarc.py @@ -1002,10 +1002,8 @@ def test_eventarc_client_create_channel_credentials_file(client_class, transport @pytest.mark.parametrize("request_type", [ - eventarc.GetTriggerRequest({ - }), - { - }, + eventarc.GetTriggerRequest(), + {}, ]) def test_get_trigger(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -1146,8 +1144,8 @@ async def test_get_trigger_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetTriggerRequest({ }), - { }, + eventarc.GetTriggerRequest(), + {}, ]) async def test_get_trigger_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -1337,10 +1335,8 @@ async def test_get_trigger_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListTriggersRequest({ - }), - { - }, + eventarc.ListTriggersRequest(), + {}, ]) def test_list_triggers(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -1477,8 +1473,8 @@ async def test_list_triggers_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListTriggersRequest({ }), - { }, + eventarc.ListTriggersRequest(), + {}, ]) async def test_list_triggers_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -1852,10 +1848,8 @@ async def test_list_triggers_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateTriggerRequest({ - }), - { - }, + eventarc.CreateTriggerRequest(), + {}, ]) def test_create_trigger(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -1993,8 +1987,8 @@ async def test_create_trigger_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateTriggerRequest({ }), - { }, + eventarc.CreateTriggerRequest(), + {}, ]) async def test_create_trigger_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -2193,10 +2187,8 @@ async def test_create_trigger_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateTriggerRequest({ - }), - { - }, + eventarc.UpdateTriggerRequest(), + {}, ]) def test_update_trigger(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -2330,8 +2322,8 @@ async def test_update_trigger_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateTriggerRequest({ }), - { }, + eventarc.UpdateTriggerRequest(), + {}, ]) async def test_update_trigger_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -2530,10 +2522,8 @@ async def test_update_trigger_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteTriggerRequest({ - }), - { - }, + eventarc.DeleteTriggerRequest(), + {}, ]) def test_delete_trigger(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -2671,8 +2661,8 @@ async def test_delete_trigger_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteTriggerRequest({ }), - { }, + eventarc.DeleteTriggerRequest(), + {}, ]) async def test_delete_trigger_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -2861,10 +2851,8 @@ async def test_delete_trigger_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetChannelRequest({ - }), - { - }, + eventarc.GetChannelRequest(), + {}, ]) def test_get_channel(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -3006,8 +2994,8 @@ async def test_get_channel_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetChannelRequest({ }), - { }, + eventarc.GetChannelRequest(), + {}, ]) async def test_get_channel_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -3197,10 +3185,8 @@ async def test_get_channel_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListChannelsRequest({ - }), - { - }, + eventarc.ListChannelsRequest(), + {}, ]) def test_list_channels(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -3335,8 +3321,8 @@ async def test_list_channels_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListChannelsRequest({ }), - { }, + eventarc.ListChannelsRequest(), + {}, ]) async def test_list_channels_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -3710,10 +3696,8 @@ async def test_list_channels_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateChannelRequest({ - }), - { - }, + eventarc.CreateChannelRequest(), + {}, ]) def test_create_channel(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -3851,8 +3835,8 @@ async def test_create_channel_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateChannelRequest({ }), - { }, + eventarc.CreateChannelRequest(), + {}, ]) async def test_create_channel_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -4051,10 +4035,8 @@ async def test_create_channel_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateChannelRequest({ - }), - { - }, + eventarc.UpdateChannelRequest(), + {}, ]) def test_update_channel(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -4188,8 +4170,8 @@ async def test_update_channel_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateChannelRequest({ }), - { }, + eventarc.UpdateChannelRequest(), + {}, ]) async def test_update_channel_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -4378,10 +4360,8 @@ async def test_update_channel_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteChannelRequest({ - }), - { - }, + eventarc.DeleteChannelRequest(), + {}, ]) def test_delete_channel(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -4517,8 +4497,8 @@ async def test_delete_channel_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteChannelRequest({ }), - { }, + eventarc.DeleteChannelRequest(), + {}, ]) async def test_delete_channel_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -4697,10 +4677,8 @@ async def test_delete_channel_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetProviderRequest({ - }), - { - }, + eventarc.GetProviderRequest(), + {}, ]) def test_get_provider(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -4831,8 +4809,8 @@ async def test_get_provider_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetProviderRequest({ }), - { }, + eventarc.GetProviderRequest(), + {}, ]) async def test_get_provider_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -5012,10 +4990,8 @@ async def test_get_provider_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListProvidersRequest({ - }), - { - }, + eventarc.ListProvidersRequest(), + {}, ]) def test_list_providers(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -5152,8 +5128,8 @@ async def test_list_providers_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListProvidersRequest({ }), - { }, + eventarc.ListProvidersRequest(), + {}, ]) async def test_list_providers_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -5527,10 +5503,8 @@ async def test_list_providers_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.GetChannelConnectionRequest({ - }), - { - }, + eventarc.GetChannelConnectionRequest(), + {}, ]) def test_get_channel_connection(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -5665,8 +5639,8 @@ async def test_get_channel_connection_async_use_cached_wrapped_rpc(transport: st @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetChannelConnectionRequest({ }), - { }, + eventarc.GetChannelConnectionRequest(), + {}, ]) async def test_get_channel_connection_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -5850,10 +5824,8 @@ async def test_get_channel_connection_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListChannelConnectionsRequest({ - }), - { - }, + eventarc.ListChannelConnectionsRequest(), + {}, ]) def test_list_channel_connections(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -5986,8 +5958,8 @@ async def test_list_channel_connections_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListChannelConnectionsRequest({ }), - { }, + eventarc.ListChannelConnectionsRequest(), + {}, ]) async def test_list_channel_connections_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -6361,10 +6333,8 @@ async def test_list_channel_connections_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateChannelConnectionRequest({ - }), - { - }, + eventarc.CreateChannelConnectionRequest(), + {}, ]) def test_create_channel_connection(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -6502,8 +6472,8 @@ async def test_create_channel_connection_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateChannelConnectionRequest({ }), - { }, + eventarc.CreateChannelConnectionRequest(), + {}, ]) async def test_create_channel_connection_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -6702,10 +6672,8 @@ async def test_create_channel_connection_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteChannelConnectionRequest({ - }), - { - }, + eventarc.DeleteChannelConnectionRequest(), + {}, ]) def test_delete_channel_connection(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -6841,8 +6809,8 @@ async def test_delete_channel_connection_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteChannelConnectionRequest({ }), - { }, + eventarc.DeleteChannelConnectionRequest(), + {}, ]) async def test_delete_channel_connection_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -7021,10 +6989,8 @@ async def test_delete_channel_connection_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetGoogleChannelConfigRequest({ - }), - { - }, + eventarc.GetGoogleChannelConfigRequest(), + {}, ]) def test_get_google_channel_config(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -7155,8 +7121,8 @@ async def test_get_google_channel_config_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetGoogleChannelConfigRequest({ }), - { }, + eventarc.GetGoogleChannelConfigRequest(), + {}, ]) async def test_get_google_channel_config_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -7336,10 +7302,8 @@ async def test_get_google_channel_config_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateGoogleChannelConfigRequest({ - }), - { - }, + eventarc.UpdateGoogleChannelConfigRequest(), + {}, ]) def test_update_google_channel_config(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -7468,8 +7432,8 @@ async def test_update_google_channel_config_async_use_cached_wrapped_rpc(transpo @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateGoogleChannelConfigRequest({ }), - { }, + eventarc.UpdateGoogleChannelConfigRequest(), + {}, ]) async def test_update_google_channel_config_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -7659,10 +7623,8 @@ async def test_update_google_channel_config_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetMessageBusRequest({ - }), - { - }, + eventarc.GetMessageBusRequest(), + {}, ]) def test_get_message_bus(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -7799,8 +7761,8 @@ async def test_get_message_bus_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetMessageBusRequest({ }), - { }, + eventarc.GetMessageBusRequest(), + {}, ]) async def test_get_message_bus_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -7986,10 +7948,8 @@ async def test_get_message_bus_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListMessageBusesRequest({ - }), - { - }, + eventarc.ListMessageBusesRequest(), + {}, ]) def test_list_message_buses(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -8126,8 +8086,8 @@ async def test_list_message_buses_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListMessageBusesRequest({ }), - { }, + eventarc.ListMessageBusesRequest(), + {}, ]) async def test_list_message_buses_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -8501,10 +8461,8 @@ async def test_list_message_buses_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.ListMessageBusEnrollmentsRequest({ - }), - { - }, + eventarc.ListMessageBusEnrollmentsRequest(), + {}, ]) def test_list_message_bus_enrollments(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -8639,8 +8597,8 @@ async def test_list_message_bus_enrollments_async_use_cached_wrapped_rpc(transpo @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListMessageBusEnrollmentsRequest({ }), - { }, + eventarc.ListMessageBusEnrollmentsRequest(), + {}, ]) async def test_list_message_bus_enrollments_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -9016,10 +8974,8 @@ async def test_list_message_bus_enrollments_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateMessageBusRequest({ - }), - { - }, + eventarc.CreateMessageBusRequest(), + {}, ]) def test_create_message_bus(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -9157,8 +9113,8 @@ async def test_create_message_bus_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateMessageBusRequest({ }), - { }, + eventarc.CreateMessageBusRequest(), + {}, ]) async def test_create_message_bus_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -9357,10 +9313,8 @@ async def test_create_message_bus_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateMessageBusRequest({ - }), - { - }, + eventarc.UpdateMessageBusRequest(), + {}, ]) def test_update_message_bus(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -9494,8 +9448,8 @@ async def test_update_message_bus_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateMessageBusRequest({ }), - { }, + eventarc.UpdateMessageBusRequest(), + {}, ]) async def test_update_message_bus_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -9684,10 +9638,8 @@ async def test_update_message_bus_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteMessageBusRequest({ - }), - { - }, + eventarc.DeleteMessageBusRequest(), + {}, ]) def test_delete_message_bus(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -9825,8 +9777,8 @@ async def test_delete_message_bus_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteMessageBusRequest({ }), - { }, + eventarc.DeleteMessageBusRequest(), + {}, ]) async def test_delete_message_bus_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -10015,10 +9967,8 @@ async def test_delete_message_bus_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetEnrollmentRequest({ - }), - { - }, + eventarc.GetEnrollmentRequest(), + {}, ]) def test_get_enrollment(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -10159,8 +10109,8 @@ async def test_get_enrollment_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetEnrollmentRequest({ }), - { }, + eventarc.GetEnrollmentRequest(), + {}, ]) async def test_get_enrollment_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -10350,10 +10300,8 @@ async def test_get_enrollment_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListEnrollmentsRequest({ - }), - { - }, + eventarc.ListEnrollmentsRequest(), + {}, ]) def test_list_enrollments(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -10490,8 +10438,8 @@ async def test_list_enrollments_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListEnrollmentsRequest({ }), - { }, + eventarc.ListEnrollmentsRequest(), + {}, ]) async def test_list_enrollments_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -10865,10 +10813,8 @@ async def test_list_enrollments_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateEnrollmentRequest({ - }), - { - }, + eventarc.CreateEnrollmentRequest(), + {}, ]) def test_create_enrollment(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -11006,8 +10952,8 @@ async def test_create_enrollment_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateEnrollmentRequest({ }), - { }, + eventarc.CreateEnrollmentRequest(), + {}, ]) async def test_create_enrollment_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -11206,10 +11152,8 @@ async def test_create_enrollment_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateEnrollmentRequest({ - }), - { - }, + eventarc.UpdateEnrollmentRequest(), + {}, ]) def test_update_enrollment(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -11343,8 +11287,8 @@ async def test_update_enrollment_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateEnrollmentRequest({ }), - { }, + eventarc.UpdateEnrollmentRequest(), + {}, ]) async def test_update_enrollment_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -11533,10 +11477,8 @@ async def test_update_enrollment_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteEnrollmentRequest({ - }), - { - }, + eventarc.DeleteEnrollmentRequest(), + {}, ]) def test_delete_enrollment(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -11674,8 +11616,8 @@ async def test_delete_enrollment_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteEnrollmentRequest({ }), - { }, + eventarc.DeleteEnrollmentRequest(), + {}, ]) async def test_delete_enrollment_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -11864,10 +11806,8 @@ async def test_delete_enrollment_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetPipelineRequest({ - }), - { - }, + eventarc.GetPipelineRequest(), + {}, ]) def test_get_pipeline(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -12006,8 +11946,8 @@ async def test_get_pipeline_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetPipelineRequest({ }), - { }, + eventarc.GetPipelineRequest(), + {}, ]) async def test_get_pipeline_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -12195,10 +12135,8 @@ async def test_get_pipeline_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListPipelinesRequest({ - }), - { - }, + eventarc.ListPipelinesRequest(), + {}, ]) def test_list_pipelines(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -12335,8 +12273,8 @@ async def test_list_pipelines_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListPipelinesRequest({ }), - { }, + eventarc.ListPipelinesRequest(), + {}, ]) async def test_list_pipelines_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -12710,10 +12648,8 @@ async def test_list_pipelines_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreatePipelineRequest({ - }), - { - }, + eventarc.CreatePipelineRequest(), + {}, ]) def test_create_pipeline(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -12851,8 +12787,8 @@ async def test_create_pipeline_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreatePipelineRequest({ }), - { }, + eventarc.CreatePipelineRequest(), + {}, ]) async def test_create_pipeline_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -13051,10 +12987,8 @@ async def test_create_pipeline_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdatePipelineRequest({ - }), - { - }, + eventarc.UpdatePipelineRequest(), + {}, ]) def test_update_pipeline(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -13188,8 +13122,8 @@ async def test_update_pipeline_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdatePipelineRequest({ }), - { }, + eventarc.UpdatePipelineRequest(), + {}, ]) async def test_update_pipeline_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -13378,10 +13312,8 @@ async def test_update_pipeline_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeletePipelineRequest({ - }), - { - }, + eventarc.DeletePipelineRequest(), + {}, ]) def test_delete_pipeline(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -13519,8 +13451,8 @@ async def test_delete_pipeline_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeletePipelineRequest({ }), - { }, + eventarc.DeletePipelineRequest(), + {}, ]) async def test_delete_pipeline_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -13709,10 +13641,8 @@ async def test_delete_pipeline_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.GetGoogleApiSourceRequest({ - }), - { - }, + eventarc.GetGoogleApiSourceRequest(), + {}, ]) def test_get_google_api_source(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -13851,8 +13781,8 @@ async def test_get_google_api_source_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.GetGoogleApiSourceRequest({ }), - { }, + eventarc.GetGoogleApiSourceRequest(), + {}, ]) async def test_get_google_api_source_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -14040,10 +13970,8 @@ async def test_get_google_api_source_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.ListGoogleApiSourcesRequest({ - }), - { - }, + eventarc.ListGoogleApiSourcesRequest(), + {}, ]) def test_list_google_api_sources(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -14180,8 +14108,8 @@ async def test_list_google_api_sources_async_use_cached_wrapped_rpc(transport: s @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.ListGoogleApiSourcesRequest({ }), - { }, + eventarc.ListGoogleApiSourcesRequest(), + {}, ]) async def test_list_google_api_sources_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -14555,10 +14483,8 @@ async def test_list_google_api_sources_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - eventarc.CreateGoogleApiSourceRequest({ - }), - { - }, + eventarc.CreateGoogleApiSourceRequest(), + {}, ]) def test_create_google_api_source(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -14696,8 +14622,8 @@ async def test_create_google_api_source_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.CreateGoogleApiSourceRequest({ }), - { }, + eventarc.CreateGoogleApiSourceRequest(), + {}, ]) async def test_create_google_api_source_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -14896,10 +14822,8 @@ async def test_create_google_api_source_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.UpdateGoogleApiSourceRequest({ - }), - { - }, + eventarc.UpdateGoogleApiSourceRequest(), + {}, ]) def test_update_google_api_source(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -15033,8 +14957,8 @@ async def test_update_google_api_source_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.UpdateGoogleApiSourceRequest({ }), - { }, + eventarc.UpdateGoogleApiSourceRequest(), + {}, ]) async def test_update_google_api_source_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( @@ -15223,10 +15147,8 @@ async def test_update_google_api_source_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - eventarc.DeleteGoogleApiSourceRequest({ - }), - { - }, + eventarc.DeleteGoogleApiSourceRequest(), + {}, ]) def test_delete_google_api_source(request_type, transport: str = 'grpc'): client = EventarcClient( @@ -15364,8 +15286,8 @@ async def test_delete_google_api_source_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - eventarc.DeleteGoogleApiSourceRequest({ }), - { }, + eventarc.DeleteGoogleApiSourceRequest(), + {}, ]) async def test_delete_google_api_source_async(request_type, transport: str = 'grpc_asyncio'): client = EventarcAsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_config_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_config_service_v2.py index 70f2b1ee57de..57522704960d 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_config_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_config_service_v2.py @@ -960,10 +960,8 @@ def test_config_service_v2_client_create_channel_credentials_file(client_class, @pytest.mark.parametrize("request_type", [ - logging_config.ListBucketsRequest({ - }), - { - }, + logging_config.ListBucketsRequest(), + {}, ]) def test_list_buckets(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -1094,8 +1092,8 @@ async def test_list_buckets_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListBucketsRequest({ }), - { }, + logging_config.ListBucketsRequest(), + {}, ]) async def test_list_buckets_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -1467,10 +1465,8 @@ async def test_list_buckets_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetBucketRequest({ - }), - { - }, + logging_config.GetBucketRequest(), + {}, ]) def test_get_bucket(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -1611,8 +1607,8 @@ async def test_get_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetBucketRequest({ }), - { }, + logging_config.GetBucketRequest(), + {}, ]) async def test_get_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -1720,10 +1716,8 @@ async def test_get_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ - }), - { - }, + logging_config.CreateBucketRequest(), + {}, ]) def test_create_bucket_async(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -1861,8 +1855,8 @@ async def test_create_bucket_async_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ }), - { }, + logging_config.CreateBucketRequest(), + {}, ]) async def test_create_bucket_async_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -1957,10 +1951,8 @@ async def test_create_bucket_async_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ - }), - { - }, + logging_config.UpdateBucketRequest(), + {}, ]) def test_update_bucket_async(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -2096,8 +2088,8 @@ async def test_update_bucket_async_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ }), - { }, + logging_config.UpdateBucketRequest(), + {}, ]) async def test_update_bucket_async_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -2192,10 +2184,8 @@ async def test_update_bucket_async_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ - }), - { - }, + logging_config.CreateBucketRequest(), + {}, ]) def test_create_bucket(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -2338,8 +2328,8 @@ async def test_create_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ }), - { }, + logging_config.CreateBucketRequest(), + {}, ]) async def test_create_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -2447,10 +2437,8 @@ async def test_create_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ - }), - { - }, + logging_config.UpdateBucketRequest(), + {}, ]) def test_update_bucket(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -2591,8 +2579,8 @@ async def test_update_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ }), - { }, + logging_config.UpdateBucketRequest(), + {}, ]) async def test_update_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -2700,10 +2688,8 @@ async def test_update_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteBucketRequest({ - }), - { - }, + logging_config.DeleteBucketRequest(), + {}, ]) def test_delete_bucket(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -2829,8 +2815,8 @@ async def test_delete_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteBucketRequest({ }), - { }, + logging_config.DeleteBucketRequest(), + {}, ]) async def test_delete_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -2923,10 +2909,8 @@ async def test_delete_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UndeleteBucketRequest({ - }), - { - }, + logging_config.UndeleteBucketRequest(), + {}, ]) def test_undelete_bucket(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -3052,8 +3036,8 @@ async def test_undelete_bucket_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UndeleteBucketRequest({ }), - { }, + logging_config.UndeleteBucketRequest(), + {}, ]) async def test_undelete_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -3146,10 +3130,8 @@ async def test_undelete_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListViewsRequest({ - }), - { - }, + logging_config.ListViewsRequest(), + {}, ]) def test_list_views(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -3280,8 +3262,8 @@ async def test_list_views_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListViewsRequest({ }), - { }, + logging_config.ListViewsRequest(), + {}, ]) async def test_list_views_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -3653,10 +3635,8 @@ async def test_list_views_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetViewRequest({ - }), - { - }, + logging_config.GetViewRequest(), + {}, ]) def test_get_view(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -3789,8 +3769,8 @@ async def test_get_view_async_use_cached_wrapped_rpc(transport: str = "grpc_asyn @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetViewRequest({ }), - { }, + logging_config.GetViewRequest(), + {}, ]) async def test_get_view_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -3890,10 +3870,8 @@ async def test_get_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateViewRequest({ - }), - { - }, + logging_config.CreateViewRequest(), + {}, ]) def test_create_view(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -4028,8 +4006,8 @@ async def test_create_view_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateViewRequest({ }), - { }, + logging_config.CreateViewRequest(), + {}, ]) async def test_create_view_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -4129,10 +4107,8 @@ async def test_create_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateViewRequest({ - }), - { - }, + logging_config.UpdateViewRequest(), + {}, ]) def test_update_view(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -4265,8 +4241,8 @@ async def test_update_view_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateViewRequest({ }), - { }, + logging_config.UpdateViewRequest(), + {}, ]) async def test_update_view_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -4366,10 +4342,8 @@ async def test_update_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteViewRequest({ - }), - { - }, + logging_config.DeleteViewRequest(), + {}, ]) def test_delete_view(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -4495,8 +4469,8 @@ async def test_delete_view_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteViewRequest({ }), - { }, + logging_config.DeleteViewRequest(), + {}, ]) async def test_delete_view_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -4589,10 +4563,8 @@ async def test_delete_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListSinksRequest({ - }), - { - }, + logging_config.ListSinksRequest(), + {}, ]) def test_list_sinks(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -4723,8 +4695,8 @@ async def test_list_sinks_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListSinksRequest({ }), - { }, + logging_config.ListSinksRequest(), + {}, ]) async def test_list_sinks_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -5096,10 +5068,8 @@ async def test_list_sinks_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetSinkRequest({ - }), - { - }, + logging_config.GetSinkRequest(), + {}, ]) def test_get_sink(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -5242,8 +5212,8 @@ async def test_get_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_asyn @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetSinkRequest({ }), - { }, + logging_config.GetSinkRequest(), + {}, ]) async def test_get_sink_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -5435,10 +5405,8 @@ async def test_get_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateSinkRequest({ - }), - { - }, + logging_config.CreateSinkRequest(), + {}, ]) def test_create_sink(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -5581,8 +5549,8 @@ async def test_create_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateSinkRequest({ }), - { }, + logging_config.CreateSinkRequest(), + {}, ]) async def test_create_sink_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -5784,10 +5752,8 @@ async def test_create_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSinkRequest({ - }), - { - }, + logging_config.UpdateSinkRequest(), + {}, ]) def test_update_sink(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -5930,8 +5896,8 @@ async def test_update_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSinkRequest({ }), - { }, + logging_config.UpdateSinkRequest(), + {}, ]) async def test_update_sink_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -6143,10 +6109,8 @@ async def test_update_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteSinkRequest({ - }), - { - }, + logging_config.DeleteSinkRequest(), + {}, ]) def test_delete_sink(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -6272,8 +6236,8 @@ async def test_delete_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteSinkRequest({ }), - { }, + logging_config.DeleteSinkRequest(), + {}, ]) async def test_delete_sink_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -6448,10 +6412,8 @@ async def test_delete_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateLinkRequest({ - }), - { - }, + logging_config.CreateLinkRequest(), + {}, ]) def test_create_link(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -6589,8 +6551,8 @@ async def test_create_link_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateLinkRequest({ }), - { }, + logging_config.CreateLinkRequest(), + {}, ]) async def test_create_link_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -6789,10 +6751,8 @@ async def test_create_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteLinkRequest({ - }), - { - }, + logging_config.DeleteLinkRequest(), + {}, ]) def test_delete_link(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -6928,8 +6888,8 @@ async def test_delete_link_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteLinkRequest({ }), - { }, + logging_config.DeleteLinkRequest(), + {}, ]) async def test_delete_link_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -7108,10 +7068,8 @@ async def test_delete_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListLinksRequest({ - }), - { - }, + logging_config.ListLinksRequest(), + {}, ]) def test_list_links(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -7242,8 +7200,8 @@ async def test_list_links_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListLinksRequest({ }), - { }, + logging_config.ListLinksRequest(), + {}, ]) async def test_list_links_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -7615,10 +7573,8 @@ async def test_list_links_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetLinkRequest({ - }), - { - }, + logging_config.GetLinkRequest(), + {}, ]) def test_get_link(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -7751,8 +7707,8 @@ async def test_get_link_async_use_cached_wrapped_rpc(transport: str = "grpc_asyn @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetLinkRequest({ }), - { }, + logging_config.GetLinkRequest(), + {}, ]) async def test_get_link_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -7934,10 +7890,8 @@ async def test_get_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListExclusionsRequest({ - }), - { - }, + logging_config.ListExclusionsRequest(), + {}, ]) def test_list_exclusions(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -8068,8 +8022,8 @@ async def test_list_exclusions_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListExclusionsRequest({ }), - { }, + logging_config.ListExclusionsRequest(), + {}, ]) async def test_list_exclusions_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -8441,10 +8395,8 @@ async def test_list_exclusions_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetExclusionRequest({ - }), - { - }, + logging_config.GetExclusionRequest(), + {}, ]) def test_get_exclusion(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -8579,8 +8531,8 @@ async def test_get_exclusion_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetExclusionRequest({ }), - { }, + logging_config.GetExclusionRequest(), + {}, ]) async def test_get_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -8764,10 +8716,8 @@ async def test_get_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateExclusionRequest({ - }), - { - }, + logging_config.CreateExclusionRequest(), + {}, ]) def test_create_exclusion(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -8902,8 +8852,8 @@ async def test_create_exclusion_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateExclusionRequest({ }), - { }, + logging_config.CreateExclusionRequest(), + {}, ]) async def test_create_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -9097,10 +9047,8 @@ async def test_create_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateExclusionRequest({ - }), - { - }, + logging_config.UpdateExclusionRequest(), + {}, ]) def test_update_exclusion(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -9235,8 +9183,8 @@ async def test_update_exclusion_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateExclusionRequest({ }), - { }, + logging_config.UpdateExclusionRequest(), + {}, ]) async def test_update_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -9440,10 +9388,8 @@ async def test_update_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteExclusionRequest({ - }), - { - }, + logging_config.DeleteExclusionRequest(), + {}, ]) def test_delete_exclusion(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -9569,8 +9515,8 @@ async def test_delete_exclusion_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteExclusionRequest({ }), - { }, + logging_config.DeleteExclusionRequest(), + {}, ]) async def test_delete_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -9745,10 +9691,8 @@ async def test_delete_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.GetCmekSettingsRequest({ - }), - { - }, + logging_config.GetCmekSettingsRequest(), + {}, ]) def test_get_cmek_settings(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -9883,8 +9827,8 @@ async def test_get_cmek_settings_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetCmekSettingsRequest({ }), - { }, + logging_config.GetCmekSettingsRequest(), + {}, ]) async def test_get_cmek_settings_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -9986,10 +9930,8 @@ async def test_get_cmek_settings_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateCmekSettingsRequest({ - }), - { - }, + logging_config.UpdateCmekSettingsRequest(), + {}, ]) def test_update_cmek_settings(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -10124,8 +10066,8 @@ async def test_update_cmek_settings_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateCmekSettingsRequest({ }), - { }, + logging_config.UpdateCmekSettingsRequest(), + {}, ]) async def test_update_cmek_settings_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -10227,10 +10169,8 @@ async def test_update_cmek_settings_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.GetSettingsRequest({ - }), - { - }, + logging_config.GetSettingsRequest(), + {}, ]) def test_get_settings(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -10367,8 +10307,8 @@ async def test_get_settings_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetSettingsRequest({ }), - { }, + logging_config.GetSettingsRequest(), + {}, ]) async def test_get_settings_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -10554,10 +10494,8 @@ async def test_get_settings_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSettingsRequest({ - }), - { - }, + logging_config.UpdateSettingsRequest(), + {}, ]) def test_update_settings(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -10694,8 +10632,8 @@ async def test_update_settings_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSettingsRequest({ }), - { }, + logging_config.UpdateSettingsRequest(), + {}, ]) async def test_update_settings_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( @@ -10891,10 +10829,8 @@ async def test_update_settings_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CopyLogEntriesRequest({ - }), - { - }, + logging_config.CopyLogEntriesRequest(), + {}, ]) def test_copy_log_entries(request_type, transport: str = 'grpc'): client = ConfigServiceV2Client( @@ -11034,8 +10970,8 @@ async def test_copy_log_entries_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CopyLogEntriesRequest({ }), - { }, + logging_config.CopyLogEntriesRequest(), + {}, ]) async def test_copy_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = ConfigServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_logging_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_logging_service_v2.py index d17295af4442..544b2fd557db 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_logging_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_logging_service_v2.py @@ -962,10 +962,8 @@ def test_logging_service_v2_client_create_channel_credentials_file(client_class, @pytest.mark.parametrize("request_type", [ - logging.DeleteLogRequest({ - }), - { - }, + logging.DeleteLogRequest(), + {}, ]) def test_delete_log(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1091,8 +1089,8 @@ async def test_delete_log_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.DeleteLogRequest({ }), - { }, + logging.DeleteLogRequest(), + {}, ]) async def test_delete_log_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -1267,10 +1265,8 @@ async def test_delete_log_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging.WriteLogEntriesRequest({ - }), - { - }, + logging.WriteLogEntriesRequest(), + {}, ]) def test_write_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1397,8 +1393,8 @@ async def test_write_log_entries_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.WriteLogEntriesRequest({ }), - { }, + logging.WriteLogEntriesRequest(), + {}, ]) async def test_write_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -1542,10 +1538,8 @@ async def test_write_log_entries_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging.ListLogEntriesRequest({ - }), - { - }, + logging.ListLogEntriesRequest(), + {}, ]) def test_list_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1678,8 +1672,8 @@ async def test_list_log_entries_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListLogEntriesRequest({ }), - { }, + logging.ListLogEntriesRequest(), + {}, ]) async def test_list_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2004,10 +1998,8 @@ async def test_list_log_entries_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.ListMonitoredResourceDescriptorsRequest({ - }), - { - }, + logging.ListMonitoredResourceDescriptorsRequest(), + {}, ]) def test_list_monitored_resource_descriptors(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2136,8 +2128,8 @@ async def test_list_monitored_resource_descriptors_async_use_cached_wrapped_rpc( @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListMonitoredResourceDescriptorsRequest({ }), - { }, + logging.ListMonitoredResourceDescriptorsRequest(), + {}, ]) async def test_list_monitored_resource_descriptors_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2360,10 +2352,8 @@ async def test_list_monitored_resource_descriptors_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.ListLogsRequest({ - }), - { - }, + logging.ListLogsRequest(), + {}, ]) def test_list_logs(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2496,8 +2486,8 @@ async def test_list_logs_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListLogsRequest({ }), - { }, + logging.ListLogsRequest(), + {}, ]) async def test_list_logs_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2871,10 +2861,8 @@ async def test_list_logs_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.TailLogEntriesRequest({ - }), - { - }, + logging.TailLogEntriesRequest(), + {}, ]) def test_tail_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2972,8 +2960,8 @@ async def test_tail_log_entries_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.TailLogEntriesRequest({ }), - { }, + logging.TailLogEntriesRequest(), + {}, ]) async def test_tail_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_metrics_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_metrics_service_v2.py index 44f71aaf1ecc..9f598dbcf95e 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_metrics_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging/tests/unit/gapic/logging_v2/test_metrics_service_v2.py @@ -960,10 +960,8 @@ def test_metrics_service_v2_client_create_channel_credentials_file(client_class, @pytest.mark.parametrize("request_type", [ - logging_metrics.ListLogMetricsRequest({ - }), - { - }, + logging_metrics.ListLogMetricsRequest(), + {}, ]) def test_list_log_metrics(request_type, transport: str = 'grpc'): client = MetricsServiceV2Client( @@ -1094,8 +1092,8 @@ async def test_list_log_metrics_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.ListLogMetricsRequest({ }), - { }, + logging_metrics.ListLogMetricsRequest(), + {}, ]) async def test_list_log_metrics_async(request_type, transport: str = 'grpc_asyncio'): client = MetricsServiceV2AsyncClient( @@ -1467,10 +1465,8 @@ async def test_list_log_metrics_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_metrics.GetLogMetricRequest({ - }), - { - }, + logging_metrics.GetLogMetricRequest(), + {}, ]) def test_get_log_metric(request_type, transport: str = 'grpc'): client = MetricsServiceV2Client( @@ -1611,8 +1607,8 @@ async def test_get_log_metric_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.GetLogMetricRequest({ }), - { }, + logging_metrics.GetLogMetricRequest(), + {}, ]) async def test_get_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = MetricsServiceV2AsyncClient( @@ -1802,10 +1798,8 @@ async def test_get_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.CreateLogMetricRequest({ - }), - { - }, + logging_metrics.CreateLogMetricRequest(), + {}, ]) def test_create_log_metric(request_type, transport: str = 'grpc'): client = MetricsServiceV2Client( @@ -1946,8 +1940,8 @@ async def test_create_log_metric_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.CreateLogMetricRequest({ }), - { }, + logging_metrics.CreateLogMetricRequest(), + {}, ]) async def test_create_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = MetricsServiceV2AsyncClient( @@ -2147,10 +2141,8 @@ async def test_create_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.UpdateLogMetricRequest({ - }), - { - }, + logging_metrics.UpdateLogMetricRequest(), + {}, ]) def test_update_log_metric(request_type, transport: str = 'grpc'): client = MetricsServiceV2Client( @@ -2291,8 +2283,8 @@ async def test_update_log_metric_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.UpdateLogMetricRequest({ }), - { }, + logging_metrics.UpdateLogMetricRequest(), + {}, ]) async def test_update_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = MetricsServiceV2AsyncClient( @@ -2492,10 +2484,8 @@ async def test_update_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.DeleteLogMetricRequest({ - }), - { - }, + logging_metrics.DeleteLogMetricRequest(), + {}, ]) def test_delete_log_metric(request_type, transport: str = 'grpc'): client = MetricsServiceV2Client( @@ -2621,8 +2611,8 @@ async def test_delete_log_metric_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.DeleteLogMetricRequest({ }), - { }, + logging_metrics.DeleteLogMetricRequest(), + {}, ]) async def test_delete_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = MetricsServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_config_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_config_service_v2.py index 6d3e18c4acdc..9152aa72c6a1 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_config_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_config_service_v2.py @@ -960,10 +960,8 @@ def test_base_config_service_v2_client_create_channel_credentials_file(client_cl @pytest.mark.parametrize("request_type", [ - logging_config.ListBucketsRequest({ - }), - { - }, + logging_config.ListBucketsRequest(), + {}, ]) def test_list_buckets(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -1094,8 +1092,8 @@ async def test_list_buckets_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListBucketsRequest({ }), - { }, + logging_config.ListBucketsRequest(), + {}, ]) async def test_list_buckets_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -1467,10 +1465,8 @@ async def test_list_buckets_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetBucketRequest({ - }), - { - }, + logging_config.GetBucketRequest(), + {}, ]) def test_get_bucket(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -1611,8 +1607,8 @@ async def test_get_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetBucketRequest({ }), - { }, + logging_config.GetBucketRequest(), + {}, ]) async def test_get_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -1720,10 +1716,8 @@ async def test_get_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ - }), - { - }, + logging_config.CreateBucketRequest(), + {}, ]) def test_create_bucket_async(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -1861,8 +1855,8 @@ async def test_create_bucket_async_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ }), - { }, + logging_config.CreateBucketRequest(), + {}, ]) async def test_create_bucket_async_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -1957,10 +1951,8 @@ async def test_create_bucket_async_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ - }), - { - }, + logging_config.UpdateBucketRequest(), + {}, ]) def test_update_bucket_async(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -2096,8 +2088,8 @@ async def test_update_bucket_async_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ }), - { }, + logging_config.UpdateBucketRequest(), + {}, ]) async def test_update_bucket_async_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -2192,10 +2184,8 @@ async def test_update_bucket_async_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ - }), - { - }, + logging_config.CreateBucketRequest(), + {}, ]) def test_create_bucket(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -2338,8 +2328,8 @@ async def test_create_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateBucketRequest({ }), - { }, + logging_config.CreateBucketRequest(), + {}, ]) async def test_create_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -2447,10 +2437,8 @@ async def test_create_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ - }), - { - }, + logging_config.UpdateBucketRequest(), + {}, ]) def test_update_bucket(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -2591,8 +2579,8 @@ async def test_update_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateBucketRequest({ }), - { }, + logging_config.UpdateBucketRequest(), + {}, ]) async def test_update_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -2700,10 +2688,8 @@ async def test_update_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteBucketRequest({ - }), - { - }, + logging_config.DeleteBucketRequest(), + {}, ]) def test_delete_bucket(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -2829,8 +2815,8 @@ async def test_delete_bucket_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteBucketRequest({ }), - { }, + logging_config.DeleteBucketRequest(), + {}, ]) async def test_delete_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -2923,10 +2909,8 @@ async def test_delete_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UndeleteBucketRequest({ - }), - { - }, + logging_config.UndeleteBucketRequest(), + {}, ]) def test_undelete_bucket(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -3052,8 +3036,8 @@ async def test_undelete_bucket_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UndeleteBucketRequest({ }), - { }, + logging_config.UndeleteBucketRequest(), + {}, ]) async def test_undelete_bucket_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -3146,10 +3130,8 @@ async def test_undelete_bucket_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListViewsRequest({ - }), - { - }, + logging_config.ListViewsRequest(), + {}, ]) def test__list_views(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -3280,8 +3262,8 @@ async def test__list_views_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListViewsRequest({ }), - { }, + logging_config.ListViewsRequest(), + {}, ]) async def test__list_views_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -3653,10 +3635,8 @@ async def test__list_views_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetViewRequest({ - }), - { - }, + logging_config.GetViewRequest(), + {}, ]) def test__get_view(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -3789,8 +3769,8 @@ async def test__get_view_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetViewRequest({ }), - { }, + logging_config.GetViewRequest(), + {}, ]) async def test__get_view_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -3890,10 +3870,8 @@ async def test__get_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateViewRequest({ - }), - { - }, + logging_config.CreateViewRequest(), + {}, ]) def test__create_view(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -4028,8 +4006,8 @@ async def test__create_view_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateViewRequest({ }), - { }, + logging_config.CreateViewRequest(), + {}, ]) async def test__create_view_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -4129,10 +4107,8 @@ async def test__create_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateViewRequest({ - }), - { - }, + logging_config.UpdateViewRequest(), + {}, ]) def test__update_view(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -4265,8 +4241,8 @@ async def test__update_view_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateViewRequest({ }), - { }, + logging_config.UpdateViewRequest(), + {}, ]) async def test__update_view_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -4366,10 +4342,8 @@ async def test__update_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteViewRequest({ - }), - { - }, + logging_config.DeleteViewRequest(), + {}, ]) def test__delete_view(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -4495,8 +4469,8 @@ async def test__delete_view_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteViewRequest({ }), - { }, + logging_config.DeleteViewRequest(), + {}, ]) async def test__delete_view_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -4589,10 +4563,8 @@ async def test__delete_view_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListSinksRequest({ - }), - { - }, + logging_config.ListSinksRequest(), + {}, ]) def test__list_sinks(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -4723,8 +4695,8 @@ async def test__list_sinks_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListSinksRequest({ }), - { }, + logging_config.ListSinksRequest(), + {}, ]) async def test__list_sinks_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -5096,10 +5068,8 @@ async def test__list_sinks_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetSinkRequest({ - }), - { - }, + logging_config.GetSinkRequest(), + {}, ]) def test__get_sink(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -5242,8 +5212,8 @@ async def test__get_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetSinkRequest({ }), - { }, + logging_config.GetSinkRequest(), + {}, ]) async def test__get_sink_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -5435,10 +5405,8 @@ async def test__get_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateSinkRequest({ - }), - { - }, + logging_config.CreateSinkRequest(), + {}, ]) def test__create_sink(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -5581,8 +5549,8 @@ async def test__create_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateSinkRequest({ }), - { }, + logging_config.CreateSinkRequest(), + {}, ]) async def test__create_sink_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -5784,10 +5752,8 @@ async def test__create_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSinkRequest({ - }), - { - }, + logging_config.UpdateSinkRequest(), + {}, ]) def test__update_sink(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -5930,8 +5896,8 @@ async def test__update_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSinkRequest({ }), - { }, + logging_config.UpdateSinkRequest(), + {}, ]) async def test__update_sink_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -6143,10 +6109,8 @@ async def test__update_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteSinkRequest({ - }), - { - }, + logging_config.DeleteSinkRequest(), + {}, ]) def test__delete_sink(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -6272,8 +6236,8 @@ async def test__delete_sink_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteSinkRequest({ }), - { }, + logging_config.DeleteSinkRequest(), + {}, ]) async def test__delete_sink_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -6448,10 +6412,8 @@ async def test__delete_sink_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateLinkRequest({ - }), - { - }, + logging_config.CreateLinkRequest(), + {}, ]) def test__create_link(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -6589,8 +6551,8 @@ async def test__create_link_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateLinkRequest({ }), - { }, + logging_config.CreateLinkRequest(), + {}, ]) async def test__create_link_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -6789,10 +6751,8 @@ async def test__create_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteLinkRequest({ - }), - { - }, + logging_config.DeleteLinkRequest(), + {}, ]) def test__delete_link(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -6928,8 +6888,8 @@ async def test__delete_link_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteLinkRequest({ }), - { }, + logging_config.DeleteLinkRequest(), + {}, ]) async def test__delete_link_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -7108,10 +7068,8 @@ async def test__delete_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListLinksRequest({ - }), - { - }, + logging_config.ListLinksRequest(), + {}, ]) def test__list_links(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -7242,8 +7200,8 @@ async def test__list_links_async_use_cached_wrapped_rpc(transport: str = "grpc_a @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListLinksRequest({ }), - { }, + logging_config.ListLinksRequest(), + {}, ]) async def test__list_links_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -7615,10 +7573,8 @@ async def test__list_links_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetLinkRequest({ - }), - { - }, + logging_config.GetLinkRequest(), + {}, ]) def test__get_link(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -7751,8 +7707,8 @@ async def test__get_link_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetLinkRequest({ }), - { }, + logging_config.GetLinkRequest(), + {}, ]) async def test__get_link_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -7934,10 +7890,8 @@ async def test__get_link_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.ListExclusionsRequest({ - }), - { - }, + logging_config.ListExclusionsRequest(), + {}, ]) def test__list_exclusions(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -8068,8 +8022,8 @@ async def test__list_exclusions_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.ListExclusionsRequest({ }), - { }, + logging_config.ListExclusionsRequest(), + {}, ]) async def test__list_exclusions_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -8441,10 +8395,8 @@ async def test__list_exclusions_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_config.GetExclusionRequest({ - }), - { - }, + logging_config.GetExclusionRequest(), + {}, ]) def test__get_exclusion(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -8579,8 +8531,8 @@ async def test__get_exclusion_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetExclusionRequest({ }), - { }, + logging_config.GetExclusionRequest(), + {}, ]) async def test__get_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -8764,10 +8716,8 @@ async def test__get_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CreateExclusionRequest({ - }), - { - }, + logging_config.CreateExclusionRequest(), + {}, ]) def test__create_exclusion(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -8902,8 +8852,8 @@ async def test__create_exclusion_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CreateExclusionRequest({ }), - { }, + logging_config.CreateExclusionRequest(), + {}, ]) async def test__create_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -9097,10 +9047,8 @@ async def test__create_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateExclusionRequest({ - }), - { - }, + logging_config.UpdateExclusionRequest(), + {}, ]) def test__update_exclusion(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -9235,8 +9183,8 @@ async def test__update_exclusion_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateExclusionRequest({ }), - { }, + logging_config.UpdateExclusionRequest(), + {}, ]) async def test__update_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -9440,10 +9388,8 @@ async def test__update_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.DeleteExclusionRequest({ - }), - { - }, + logging_config.DeleteExclusionRequest(), + {}, ]) def test__delete_exclusion(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -9569,8 +9515,8 @@ async def test__delete_exclusion_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.DeleteExclusionRequest({ }), - { }, + logging_config.DeleteExclusionRequest(), + {}, ]) async def test__delete_exclusion_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -9745,10 +9691,8 @@ async def test__delete_exclusion_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.GetCmekSettingsRequest({ - }), - { - }, + logging_config.GetCmekSettingsRequest(), + {}, ]) def test__get_cmek_settings(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -9883,8 +9827,8 @@ async def test__get_cmek_settings_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetCmekSettingsRequest({ }), - { }, + logging_config.GetCmekSettingsRequest(), + {}, ]) async def test__get_cmek_settings_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -9986,10 +9930,8 @@ async def test__get_cmek_settings_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateCmekSettingsRequest({ - }), - { - }, + logging_config.UpdateCmekSettingsRequest(), + {}, ]) def test__update_cmek_settings(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -10124,8 +10066,8 @@ async def test__update_cmek_settings_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateCmekSettingsRequest({ }), - { }, + logging_config.UpdateCmekSettingsRequest(), + {}, ]) async def test__update_cmek_settings_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -10227,10 +10169,8 @@ async def test__update_cmek_settings_field_headers_async(): @pytest.mark.parametrize("request_type", [ - logging_config.GetSettingsRequest({ - }), - { - }, + logging_config.GetSettingsRequest(), + {}, ]) def test__get_settings(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -10367,8 +10307,8 @@ async def test__get_settings_async_use_cached_wrapped_rpc(transport: str = "grpc @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.GetSettingsRequest({ }), - { }, + logging_config.GetSettingsRequest(), + {}, ]) async def test__get_settings_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -10554,10 +10494,8 @@ async def test__get_settings_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSettingsRequest({ - }), - { - }, + logging_config.UpdateSettingsRequest(), + {}, ]) def test__update_settings(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -10694,8 +10632,8 @@ async def test__update_settings_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.UpdateSettingsRequest({ }), - { }, + logging_config.UpdateSettingsRequest(), + {}, ]) async def test__update_settings_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( @@ -10891,10 +10829,8 @@ async def test__update_settings_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_config.CopyLogEntriesRequest({ - }), - { - }, + logging_config.CopyLogEntriesRequest(), + {}, ]) def test__copy_log_entries(request_type, transport: str = 'grpc'): client = BaseConfigServiceV2Client( @@ -11034,8 +10970,8 @@ async def test__copy_log_entries_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_config.CopyLogEntriesRequest({ }), - { }, + logging_config.CopyLogEntriesRequest(), + {}, ]) async def test__copy_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = BaseConfigServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_logging_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_logging_service_v2.py index d17295af4442..544b2fd557db 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_logging_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_logging_service_v2.py @@ -962,10 +962,8 @@ def test_logging_service_v2_client_create_channel_credentials_file(client_class, @pytest.mark.parametrize("request_type", [ - logging.DeleteLogRequest({ - }), - { - }, + logging.DeleteLogRequest(), + {}, ]) def test_delete_log(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1091,8 +1089,8 @@ async def test_delete_log_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.DeleteLogRequest({ }), - { }, + logging.DeleteLogRequest(), + {}, ]) async def test_delete_log_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -1267,10 +1265,8 @@ async def test_delete_log_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging.WriteLogEntriesRequest({ - }), - { - }, + logging.WriteLogEntriesRequest(), + {}, ]) def test_write_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1397,8 +1393,8 @@ async def test_write_log_entries_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.WriteLogEntriesRequest({ }), - { }, + logging.WriteLogEntriesRequest(), + {}, ]) async def test_write_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -1542,10 +1538,8 @@ async def test_write_log_entries_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging.ListLogEntriesRequest({ - }), - { - }, + logging.ListLogEntriesRequest(), + {}, ]) def test_list_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -1678,8 +1672,8 @@ async def test_list_log_entries_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListLogEntriesRequest({ }), - { }, + logging.ListLogEntriesRequest(), + {}, ]) async def test_list_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2004,10 +1998,8 @@ async def test_list_log_entries_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.ListMonitoredResourceDescriptorsRequest({ - }), - { - }, + logging.ListMonitoredResourceDescriptorsRequest(), + {}, ]) def test_list_monitored_resource_descriptors(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2136,8 +2128,8 @@ async def test_list_monitored_resource_descriptors_async_use_cached_wrapped_rpc( @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListMonitoredResourceDescriptorsRequest({ }), - { }, + logging.ListMonitoredResourceDescriptorsRequest(), + {}, ]) async def test_list_monitored_resource_descriptors_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2360,10 +2352,8 @@ async def test_list_monitored_resource_descriptors_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.ListLogsRequest({ - }), - { - }, + logging.ListLogsRequest(), + {}, ]) def test_list_logs(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2496,8 +2486,8 @@ async def test_list_logs_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.ListLogsRequest({ }), - { }, + logging.ListLogsRequest(), + {}, ]) async def test_list_logs_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( @@ -2871,10 +2861,8 @@ async def test_list_logs_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging.TailLogEntriesRequest({ - }), - { - }, + logging.TailLogEntriesRequest(), + {}, ]) def test_tail_log_entries(request_type, transport: str = 'grpc'): client = LoggingServiceV2Client( @@ -2972,8 +2960,8 @@ async def test_tail_log_entries_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging.TailLogEntriesRequest({ }), - { }, + logging.TailLogEntriesRequest(), + {}, ]) async def test_tail_log_entries_async(request_type, transport: str = 'grpc_asyncio'): client = LoggingServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_metrics_service_v2.py b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_metrics_service_v2.py index d7d864d25978..0fc62ce795c0 100755 --- a/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_metrics_service_v2.py +++ b/packages/gapic-generator/tests/integration/goldens/logging_internal/tests/unit/gapic/logging_v2/test_metrics_service_v2.py @@ -960,10 +960,8 @@ def test_base_metrics_service_v2_client_create_channel_credentials_file(client_c @pytest.mark.parametrize("request_type", [ - logging_metrics.ListLogMetricsRequest({ - }), - { - }, + logging_metrics.ListLogMetricsRequest(), + {}, ]) def test__list_log_metrics(request_type, transport: str = 'grpc'): client = BaseMetricsServiceV2Client( @@ -1094,8 +1092,8 @@ async def test__list_log_metrics_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.ListLogMetricsRequest({ }), - { }, + logging_metrics.ListLogMetricsRequest(), + {}, ]) async def test__list_log_metrics_async(request_type, transport: str = 'grpc_asyncio'): client = BaseMetricsServiceV2AsyncClient( @@ -1467,10 +1465,8 @@ async def test__list_log_metrics_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - logging_metrics.GetLogMetricRequest({ - }), - { - }, + logging_metrics.GetLogMetricRequest(), + {}, ]) def test__get_log_metric(request_type, transport: str = 'grpc'): client = BaseMetricsServiceV2Client( @@ -1611,8 +1607,8 @@ async def test__get_log_metric_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.GetLogMetricRequest({ }), - { }, + logging_metrics.GetLogMetricRequest(), + {}, ]) async def test__get_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = BaseMetricsServiceV2AsyncClient( @@ -1802,10 +1798,8 @@ async def test__get_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.CreateLogMetricRequest({ - }), - { - }, + logging_metrics.CreateLogMetricRequest(), + {}, ]) def test__create_log_metric(request_type, transport: str = 'grpc'): client = BaseMetricsServiceV2Client( @@ -1946,8 +1940,8 @@ async def test__create_log_metric_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.CreateLogMetricRequest({ }), - { }, + logging_metrics.CreateLogMetricRequest(), + {}, ]) async def test__create_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = BaseMetricsServiceV2AsyncClient( @@ -2147,10 +2141,8 @@ async def test__create_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.UpdateLogMetricRequest({ - }), - { - }, + logging_metrics.UpdateLogMetricRequest(), + {}, ]) def test__update_log_metric(request_type, transport: str = 'grpc'): client = BaseMetricsServiceV2Client( @@ -2291,8 +2283,8 @@ async def test__update_log_metric_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.UpdateLogMetricRequest({ }), - { }, + logging_metrics.UpdateLogMetricRequest(), + {}, ]) async def test__update_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = BaseMetricsServiceV2AsyncClient( @@ -2492,10 +2484,8 @@ async def test__update_log_metric_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - logging_metrics.DeleteLogMetricRequest({ - }), - { - }, + logging_metrics.DeleteLogMetricRequest(), + {}, ]) def test__delete_log_metric(request_type, transport: str = 'grpc'): client = BaseMetricsServiceV2Client( @@ -2621,8 +2611,8 @@ async def test__delete_log_metric_async_use_cached_wrapped_rpc(transport: str = @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - logging_metrics.DeleteLogMetricRequest({ }), - { }, + logging_metrics.DeleteLogMetricRequest(), + {}, ]) async def test__delete_log_metric_async(request_type, transport: str = 'grpc_asyncio'): client = BaseMetricsServiceV2AsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/redis/tests/unit/gapic/redis_v1/test_cloud_redis.py b/packages/gapic-generator/tests/integration/goldens/redis/tests/unit/gapic/redis_v1/test_cloud_redis.py index 0ded4d75fab1..7d14d15849c9 100755 --- a/packages/gapic-generator/tests/integration/goldens/redis/tests/unit/gapic/redis_v1/test_cloud_redis.py +++ b/packages/gapic-generator/tests/integration/goldens/redis/tests/unit/gapic/redis_v1/test_cloud_redis.py @@ -989,10 +989,8 @@ def test_cloud_redis_client_create_channel_credentials_file(client_class, transp @pytest.mark.parametrize("request_type", [ - cloud_redis.ListInstancesRequest({ - }), - { - }, + cloud_redis.ListInstancesRequest(), + {}, ]) def test_list_instances(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -1125,8 +1123,8 @@ async def test_list_instances_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.ListInstancesRequest({ }), - { }, + cloud_redis.ListInstancesRequest(), + {}, ]) async def test_list_instances_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -1500,10 +1498,8 @@ async def test_list_instances_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceRequest({ - }), - { - }, + cloud_redis.GetInstanceRequest(), + {}, ]) def test_get_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -1684,8 +1680,8 @@ async def test_get_instance_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceRequest({ }), - { }, + cloud_redis.GetInstanceRequest(), + {}, ]) async def test_get_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -1915,10 +1911,8 @@ async def test_get_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceAuthStringRequest({ - }), - { - }, + cloud_redis.GetInstanceAuthStringRequest(), + {}, ]) def test_get_instance_auth_string(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2047,8 +2041,8 @@ async def test_get_instance_auth_string_async_use_cached_wrapped_rpc(transport: @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceAuthStringRequest({ }), - { }, + cloud_redis.GetInstanceAuthStringRequest(), + {}, ]) async def test_get_instance_auth_string_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -2226,10 +2220,8 @@ async def test_get_instance_auth_string_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.CreateInstanceRequest({ - }), - { - }, + cloud_redis.CreateInstanceRequest(), + {}, ]) def test_create_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2367,8 +2359,8 @@ async def test_create_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.CreateInstanceRequest({ }), - { }, + cloud_redis.CreateInstanceRequest(), + {}, ]) async def test_create_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -2567,10 +2559,8 @@ async def test_create_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.UpdateInstanceRequest({ - }), - { - }, + cloud_redis.UpdateInstanceRequest(), + {}, ]) def test_update_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2704,8 +2694,8 @@ async def test_update_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.UpdateInstanceRequest({ }), - { }, + cloud_redis.UpdateInstanceRequest(), + {}, ]) async def test_update_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -2894,10 +2884,8 @@ async def test_update_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.UpgradeInstanceRequest({ - }), - { - }, + cloud_redis.UpgradeInstanceRequest(), + {}, ]) def test_upgrade_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -3035,8 +3023,8 @@ async def test_upgrade_instance_async_use_cached_wrapped_rpc(transport: str = "g @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.UpgradeInstanceRequest({ }), - { }, + cloud_redis.UpgradeInstanceRequest(), + {}, ]) async def test_upgrade_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -3225,10 +3213,8 @@ async def test_upgrade_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.ImportInstanceRequest({ - }), - { - }, + cloud_redis.ImportInstanceRequest(), + {}, ]) def test_import_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -3364,8 +3350,8 @@ async def test_import_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.ImportInstanceRequest({ }), - { }, + cloud_redis.ImportInstanceRequest(), + {}, ]) async def test_import_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -3554,10 +3540,8 @@ async def test_import_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.ExportInstanceRequest({ - }), - { - }, + cloud_redis.ExportInstanceRequest(), + {}, ]) def test_export_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -3693,8 +3677,8 @@ async def test_export_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.ExportInstanceRequest({ }), - { }, + cloud_redis.ExportInstanceRequest(), + {}, ]) async def test_export_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -3883,10 +3867,8 @@ async def test_export_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.FailoverInstanceRequest({ - }), - { - }, + cloud_redis.FailoverInstanceRequest(), + {}, ]) def test_failover_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -4022,8 +4004,8 @@ async def test_failover_instance_async_use_cached_wrapped_rpc(transport: str = " @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.FailoverInstanceRequest({ }), - { }, + cloud_redis.FailoverInstanceRequest(), + {}, ]) async def test_failover_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -4212,10 +4194,8 @@ async def test_failover_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.DeleteInstanceRequest({ - }), - { - }, + cloud_redis.DeleteInstanceRequest(), + {}, ]) def test_delete_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -4351,8 +4331,8 @@ async def test_delete_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.DeleteInstanceRequest({ }), - { }, + cloud_redis.DeleteInstanceRequest(), + {}, ]) async def test_delete_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -4531,10 +4511,8 @@ async def test_delete_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.RescheduleMaintenanceRequest({ - }), - { - }, + cloud_redis.RescheduleMaintenanceRequest(), + {}, ]) def test_reschedule_maintenance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -4670,8 +4648,8 @@ async def test_reschedule_maintenance_async_use_cached_wrapped_rpc(transport: st @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.RescheduleMaintenanceRequest({ }), - { }, + cloud_redis.RescheduleMaintenanceRequest(), + {}, ]) async def test_reschedule_maintenance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/redis_selective/tests/unit/gapic/redis_v1/test_cloud_redis.py b/packages/gapic-generator/tests/integration/goldens/redis_selective/tests/unit/gapic/redis_v1/test_cloud_redis.py index d29546120e42..1076ace45ba6 100755 --- a/packages/gapic-generator/tests/integration/goldens/redis_selective/tests/unit/gapic/redis_v1/test_cloud_redis.py +++ b/packages/gapic-generator/tests/integration/goldens/redis_selective/tests/unit/gapic/redis_v1/test_cloud_redis.py @@ -989,10 +989,8 @@ def test_cloud_redis_client_create_channel_credentials_file(client_class, transp @pytest.mark.parametrize("request_type", [ - cloud_redis.ListInstancesRequest({ - }), - { - }, + cloud_redis.ListInstancesRequest(), + {}, ]) def test_list_instances(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -1125,8 +1123,8 @@ async def test_list_instances_async_use_cached_wrapped_rpc(transport: str = "grp @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.ListInstancesRequest({ }), - { }, + cloud_redis.ListInstancesRequest(), + {}, ]) async def test_list_instances_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -1500,10 +1498,8 @@ async def test_list_instances_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceRequest({ - }), - { - }, + cloud_redis.GetInstanceRequest(), + {}, ]) def test_get_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -1684,8 +1680,8 @@ async def test_get_instance_async_use_cached_wrapped_rpc(transport: str = "grpc_ @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.GetInstanceRequest({ }), - { }, + cloud_redis.GetInstanceRequest(), + {}, ]) async def test_get_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -1915,10 +1911,8 @@ async def test_get_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.CreateInstanceRequest({ - }), - { - }, + cloud_redis.CreateInstanceRequest(), + {}, ]) def test_create_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2056,8 +2050,8 @@ async def test_create_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.CreateInstanceRequest({ }), - { }, + cloud_redis.CreateInstanceRequest(), + {}, ]) async def test_create_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -2256,10 +2250,8 @@ async def test_create_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.UpdateInstanceRequest({ - }), - { - }, + cloud_redis.UpdateInstanceRequest(), + {}, ]) def test_update_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2393,8 +2385,8 @@ async def test_update_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.UpdateInstanceRequest({ }), - { }, + cloud_redis.UpdateInstanceRequest(), + {}, ]) async def test_update_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( @@ -2583,10 +2575,8 @@ async def test_update_instance_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - cloud_redis.DeleteInstanceRequest({ - }), - { - }, + cloud_redis.DeleteInstanceRequest(), + {}, ]) def test_delete_instance(request_type, transport: str = 'grpc'): client = CloudRedisClient( @@ -2722,8 +2712,8 @@ async def test_delete_instance_async_use_cached_wrapped_rpc(transport: str = "gr @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - cloud_redis.DeleteInstanceRequest({ }), - { }, + cloud_redis.DeleteInstanceRequest(), + {}, ]) async def test_delete_instance_async(request_type, transport: str = 'grpc_asyncio'): client = CloudRedisAsyncClient( diff --git a/packages/gapic-generator/tests/integration/goldens/storagebatchoperations/tests/unit/gapic/storagebatchoperations_v1/test_storage_batch_operations.py b/packages/gapic-generator/tests/integration/goldens/storagebatchoperations/tests/unit/gapic/storagebatchoperations_v1/test_storage_batch_operations.py index 15d53645f43d..66367a27be49 100755 --- a/packages/gapic-generator/tests/integration/goldens/storagebatchoperations/tests/unit/gapic/storagebatchoperations_v1/test_storage_batch_operations.py +++ b/packages/gapic-generator/tests/integration/goldens/storagebatchoperations/tests/unit/gapic/storagebatchoperations_v1/test_storage_batch_operations.py @@ -1057,10 +1057,8 @@ def test_storage_batch_operations_client_create_channel_credentials_file(client_ @pytest.mark.parametrize("request_type", [ - storage_batch_operations.ListJobsRequest({ - }), - { - }, + storage_batch_operations.ListJobsRequest(), + {}, ]) def test_list_jobs(request_type, transport: str = 'grpc'): client = StorageBatchOperationsClient( @@ -1197,8 +1195,8 @@ async def test_list_jobs_async_use_cached_wrapped_rpc(transport: str = "grpc_asy @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.ListJobsRequest({ }), - { }, + storage_batch_operations.ListJobsRequest(), + {}, ]) async def test_list_jobs_async(request_type, transport: str = 'grpc_asyncio'): client = StorageBatchOperationsAsyncClient( @@ -1572,10 +1570,8 @@ async def test_list_jobs_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - storage_batch_operations.GetJobRequest({ - }), - { - }, + storage_batch_operations.GetJobRequest(), + {}, ]) def test_get_job(request_type, transport: str = 'grpc'): client = StorageBatchOperationsClient( @@ -1712,8 +1708,8 @@ async def test_get_job_async_use_cached_wrapped_rpc(transport: str = "grpc_async @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.GetJobRequest({ }), - { }, + storage_batch_operations.GetJobRequest(), + {}, ]) async def test_get_job_async(request_type, transport: str = 'grpc_asyncio'): client = StorageBatchOperationsAsyncClient( @@ -1899,7 +1895,8 @@ async def test_get_job_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - storage_batch_operations.CreateJobRequest({ + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.CreateJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { @@ -2046,7 +2043,8 @@ async def test_create_job_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.CreateJobRequest({ "request_id": "explicit value for autopopulate-able field", }), + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.CreateJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { "request_id": "explicit value for autopopulate-able field", }, ]) async def test_create_job_async(request_type, transport: str = 'grpc_asyncio'): @@ -2247,7 +2245,8 @@ async def test_create_job_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - storage_batch_operations.DeleteJobRequest({ + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.DeleteJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { @@ -2382,7 +2381,8 @@ async def test_delete_job_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.DeleteJobRequest({ "request_id": "explicit value for autopopulate-able field", }), + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.DeleteJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { "request_id": "explicit value for autopopulate-able field", }, ]) async def test_delete_job_async(request_type, transport: str = 'grpc_asyncio'): @@ -2559,7 +2559,8 @@ async def test_delete_job_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - storage_batch_operations.CancelJobRequest({ + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.CancelJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { @@ -2695,7 +2696,8 @@ async def test_cancel_job_async_use_cached_wrapped_rpc(transport: str = "grpc_as @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.CancelJobRequest({ "request_id": "explicit value for autopopulate-able field", }), + # Pure protobuf messages (non-proto-plus) require keyword arguments. + storage_batch_operations.CancelJobRequest(**{ "request_id": "explicit value for autopopulate-able field", }), { "request_id": "explicit value for autopopulate-able field", }, ]) async def test_cancel_job_async(request_type, transport: str = 'grpc_asyncio'): @@ -2873,10 +2875,8 @@ async def test_cancel_job_flattened_error_async(): @pytest.mark.parametrize("request_type", [ - storage_batch_operations.ListBucketOperationsRequest({ - }), - { - }, + storage_batch_operations.ListBucketOperationsRequest(), + {}, ]) def test_list_bucket_operations(request_type, transport: str = 'grpc'): client = StorageBatchOperationsClient( @@ -3013,8 +3013,8 @@ async def test_list_bucket_operations_async_use_cached_wrapped_rpc(transport: st @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.ListBucketOperationsRequest({ }), - { }, + storage_batch_operations.ListBucketOperationsRequest(), + {}, ]) async def test_list_bucket_operations_async(request_type, transport: str = 'grpc_asyncio'): client = StorageBatchOperationsAsyncClient( @@ -3388,10 +3388,8 @@ async def test_list_bucket_operations_async_pages(): assert page_.raw_page.next_page_token == token @pytest.mark.parametrize("request_type", [ - storage_batch_operations.GetBucketOperationRequest({ - }), - { - }, + storage_batch_operations.GetBucketOperationRequest(), + {}, ]) def test_get_bucket_operation(request_type, transport: str = 'grpc'): client = StorageBatchOperationsClient( @@ -3524,8 +3522,8 @@ async def test_get_bucket_operation_async_use_cached_wrapped_rpc(transport: str @pytest.mark.asyncio @pytest.mark.parametrize("request_type", [ - storage_batch_operations.GetBucketOperationRequest({ }), - { }, + storage_batch_operations.GetBucketOperationRequest(), + {}, ]) async def test_get_bucket_operation_async(request_type, transport: str = 'grpc_asyncio'): client = StorageBatchOperationsAsyncClient(