Skip to content
This repository was archived by the owner on Mar 26, 2026. It is now read-only.

Commit 51b2253

Browse files
daniel-sanchedaniel-sanche
committed
updated goldens
1 parent 1a3afcd commit 51b2253

File tree

21 files changed

+592
-426
lines changed

21 files changed

+592
-426
lines changed

‎tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/async_client.py‎

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3181,9 +3181,11 @@ async def get_operation(
31813181
# The request isn't a proto-plus wrapped type,
31823182
# so it must be constructed via keyword expansion.
31833183
if request is None:
3184-
request = {}
3185-
if isinstance(request, dict):
3186-
request = operations_pb2.GetOperationRequest(**request)
3184+
request_pb = operations_pb2.GetOperationRequest()
3185+
elif isinstance(request, dict):
3186+
request_pb = operations_pb2.GetOperationRequest(**request)
3187+
else:
3188+
request_pb = request
31873189

31883190
# Wrap the RPC method; this adds retry and timeout information,
31893191
# and friendly error handling.
@@ -3193,15 +3195,15 @@ async def get_operation(
31933195
# add these here.
31943196
metadata = tuple(metadata) + (
31953197
gapic_v1.routing_header.to_grpc_metadata(
3196-
(("name", request.name),)),
3198+
(("name", request_pb.name),)),
31973199
)
31983200

31993201
# Validate the universe domain.
32003202
self._client._validate_universe_domain()
32013203

32023204
# Send the request.
32033205
response = await rpc(
3204-
request, retry=retry, timeout=timeout, metadata=metadata,)
3206+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
32053207

32063208
# Done; return the response.
32073209
return response

‎tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/client.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -623,7 +623,7 @@ def __init__(self, *,
623623
self._use_client_cert, self._use_mtls_endpoint, self._universe_domain_env = AssetServiceClient._read_environment_variables()
624624
self._client_cert_source = AssetServiceClient._get_client_cert_source(self._client_options.client_cert_source, self._use_client_cert)
625625
self._universe_domain = AssetServiceClient._get_universe_domain(universe_domain_opt, self._universe_domain_env)
626-
self._api_endpoint = None # updated below, depending on `transport`
626+
self._api_endpoint: str = "" # updated below, depending on `transport`
627627

628628
# Initialize the universe domain validation.
629629
self._is_universe_domain_valid = False

‎tests/integration/goldens/credentials/google/iam/credentials_v1/services/iam_credentials/client.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ def __init__(self, *,
560560
self._use_client_cert, self._use_mtls_endpoint, self._universe_domain_env = IAMCredentialsClient._read_environment_variables()
561561
self._client_cert_source = IAMCredentialsClient._get_client_cert_source(self._client_options.client_cert_source, self._use_client_cert)
562562
self._universe_domain = IAMCredentialsClient._get_universe_domain(universe_domain_opt, self._universe_domain_env)
563-
self._api_endpoint = None # updated below, depending on `transport`
563+
self._api_endpoint: str = "" # updated below, depending on `transport`
564564

565565
# Initialize the universe domain validation.
566566
self._is_universe_domain_valid = False

‎tests/integration/goldens/eventarc/google/cloud/eventarc_v1/services/eventarc/async_client.py‎

Lines changed: 63 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -2577,9 +2577,11 @@ async def list_operations(
25772577
# The request isn't a proto-plus wrapped type,
25782578
# so it must be constructed via keyword expansion.
25792579
if request is None:
2580-
request = {}
2581-
if isinstance(request, dict):
2582-
request = operations_pb2.ListOperationsRequest(**request)
2580+
request_pb = operations_pb2.ListOperationsRequest()
2581+
elif isinstance(request, dict):
2582+
request_pb = operations_pb2.ListOperationsRequest(**request)
2583+
else:
2584+
request_pb = request
25832585

25842586
# Wrap the RPC method; this adds retry and timeout information,
25852587
# and friendly error handling.
@@ -2589,15 +2591,15 @@ async def list_operations(
25892591
# add these here.
25902592
metadata = tuple(metadata) + (
25912593
gapic_v1.routing_header.to_grpc_metadata(
2592-
(("name", request.name),)),
2594+
(("name", request_pb.name),)),
25932595
)
25942596

25952597
# Validate the universe domain.
25962598
self._client._validate_universe_domain()
25972599

25982600
# Send the request.
25992601
response = await rpc(
2600-
request, retry=retry, timeout=timeout, metadata=metadata,)
2602+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
26012603

26022604
# Done; return the response.
26032605
return response
@@ -2631,9 +2633,11 @@ async def get_operation(
26312633
# The request isn't a proto-plus wrapped type,
26322634
# so it must be constructed via keyword expansion.
26332635
if request is None:
2634-
request = {}
2635-
if isinstance(request, dict):
2636-
request = operations_pb2.GetOperationRequest(**request)
2636+
request_pb = operations_pb2.GetOperationRequest()
2637+
elif isinstance(request, dict):
2638+
request_pb = operations_pb2.GetOperationRequest(**request)
2639+
else:
2640+
request_pb = request
26372641

26382642
# Wrap the RPC method; this adds retry and timeout information,
26392643
# and friendly error handling.
@@ -2643,15 +2647,15 @@ async def get_operation(
26432647
# add these here.
26442648
metadata = tuple(metadata) + (
26452649
gapic_v1.routing_header.to_grpc_metadata(
2646-
(("name", request.name),)),
2650+
(("name", request_pb.name),)),
26472651
)
26482652

26492653
# Validate the universe domain.
26502654
self._client._validate_universe_domain()
26512655

26522656
# Send the request.
26532657
response = await rpc(
2654-
request, retry=retry, timeout=timeout, metadata=metadata,)
2658+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
26552659

26562660
# Done; return the response.
26572661
return response
@@ -2689,9 +2693,11 @@ async def delete_operation(
26892693
# The request isn't a proto-plus wrapped type,
26902694
# so it must be constructed via keyword expansion.
26912695
if request is None:
2692-
request = {}
2693-
if isinstance(request, dict):
2694-
request = operations_pb2.DeleteOperationRequest(**request)
2696+
request_pb = operations_pb2.DeleteOperationRequest()
2697+
elif isinstance(request, dict):
2698+
request_pb = operations_pb2.DeleteOperationRequest(**request)
2699+
else:
2700+
request_pb = request
26952701

26962702
# Wrap the RPC method; this adds retry and timeout information,
26972703
# and friendly error handling.
@@ -2701,14 +2707,14 @@ async def delete_operation(
27012707
# add these here.
27022708
metadata = tuple(metadata) + (
27032709
gapic_v1.routing_header.to_grpc_metadata(
2704-
(("name", request.name),)),
2710+
(("name", request_pb.name),)),
27052711
)
27062712

27072713
# Validate the universe domain.
27082714
self._client._validate_universe_domain()
27092715

27102716
# Send the request.
2711-
await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2717+
await rpc(request_pb, retry=retry, timeout=timeout, metadata=metadata,)
27122718

27132719
async def cancel_operation(
27142720
self,
@@ -2742,9 +2748,11 @@ async def cancel_operation(
27422748
# The request isn't a proto-plus wrapped type,
27432749
# so it must be constructed via keyword expansion.
27442750
if request is None:
2745-
request = {}
2746-
if isinstance(request, dict):
2747-
request = operations_pb2.CancelOperationRequest(**request)
2751+
request_pb = operations_pb2.CancelOperationRequest()
2752+
elif isinstance(request, dict):
2753+
request_pb = operations_pb2.CancelOperationRequest(**request)
2754+
else:
2755+
request_pb = request
27482756

27492757
# Wrap the RPC method; this adds retry and timeout information,
27502758
# and friendly error handling.
@@ -2754,14 +2762,14 @@ async def cancel_operation(
27542762
# add these here.
27552763
metadata = tuple(metadata) + (
27562764
gapic_v1.routing_header.to_grpc_metadata(
2757-
(("name", request.name),)),
2765+
(("name", request_pb.name),)),
27582766
)
27592767

27602768
# Validate the universe domain.
27612769
self._client._validate_universe_domain()
27622770

27632771
# Send the request.
2764-
await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2772+
await rpc(request_pb, retry=retry, timeout=timeout, metadata=metadata,)
27652773

27662774
async def set_iam_policy(
27672775
self,
@@ -2858,9 +2866,11 @@ async def set_iam_policy(
28582866
# The request isn't a proto-plus wrapped type,
28592867
# so it must be constructed via keyword expansion.
28602868
if request is None:
2861-
request = {}
2862-
if isinstance(request, dict):
2863-
request = iam_policy_pb2.SetIamPolicyRequest(**request)
2869+
request_pb = iam_policy_pb2.SetIamPolicyRequest()
2870+
elif isinstance(request, dict):
2871+
request_pb = iam_policy_pb2.SetIamPolicyRequest(**request)
2872+
else:
2873+
request_pb = request
28642874

28652875
# Wrap the RPC method; this adds retry and timeout information,
28662876
# and friendly error handling.
@@ -2870,15 +2880,15 @@ async def set_iam_policy(
28702880
# add these here.
28712881
metadata = tuple(metadata) + (
28722882
gapic_v1.routing_header.to_grpc_metadata(
2873-
(("resource", request.resource),)),
2883+
(("resource", request_pb.resource),)),
28742884
)
28752885

28762886
# Validate the universe domain.
28772887
self._client._validate_universe_domain()
28782888

28792889
# Send the request.
28802890
response = await rpc(
2881-
request, retry=retry, timeout=timeout, metadata=metadata,)
2891+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
28822892

28832893
# Done; return the response.
28842894
return response
@@ -2979,9 +2989,11 @@ async def get_iam_policy(
29792989
# The request isn't a proto-plus wrapped type,
29802990
# so it must be constructed via keyword expansion.
29812991
if request is None:
2982-
request = {}
2983-
if isinstance(request, dict):
2984-
request = iam_policy_pb2.GetIamPolicyRequest(**request)
2992+
request_pb = iam_policy_pb2.GetIamPolicyRequest()
2993+
elif isinstance(request, dict):
2994+
request_pb = iam_policy_pb2.GetIamPolicyRequest(**request)
2995+
else:
2996+
request_pb = request
29852997

29862998
# Wrap the RPC method; this adds retry and timeout information,
29872999
# and friendly error handling.
@@ -2991,15 +3003,15 @@ async def get_iam_policy(
29913003
# add these here.
29923004
metadata = tuple(metadata) + (
29933005
gapic_v1.routing_header.to_grpc_metadata(
2994-
(("resource", request.resource),)),
3006+
(("resource", request_pb.resource),)),
29953007
)
29963008

29973009
# Validate the universe domain.
29983010
self._client._validate_universe_domain()
29993011

30003012
# Send the request.
30013013
response = await rpc(
3002-
request, retry=retry, timeout=timeout, metadata=metadata,)
3014+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
30033015

30043016
# Done; return the response.
30053017
return response
@@ -3038,9 +3050,11 @@ async def test_iam_permissions(
30383050
# The request isn't a proto-plus wrapped type,
30393051
# so it must be constructed via keyword expansion.
30403052
if request is None:
3041-
request = {}
3042-
if isinstance(request, dict):
3043-
request = iam_policy_pb2.TestIamPermissionsRequest(**request)
3053+
request_pb = iam_policy_pb2.TestIamPermissionsRequest()
3054+
elif isinstance(request, dict):
3055+
request_pb = iam_policy_pb2.TestIamPermissionsRequest(**request)
3056+
else:
3057+
request_pb = request
30443058

30453059
# Wrap the RPC method; this adds retry and timeout information,
30463060
# and friendly error handling.
@@ -3050,15 +3064,15 @@ async def test_iam_permissions(
30503064
# add these here.
30513065
metadata = tuple(metadata) + (
30523066
gapic_v1.routing_header.to_grpc_metadata(
3053-
(("resource", request.resource),)),
3067+
(("resource", request_pb.resource),)),
30543068
)
30553069

30563070
# Validate the universe domain.
30573071
self._client._validate_universe_domain()
30583072

30593073
# Send the request.
30603074
response = await rpc(
3061-
request, retry=retry, timeout=timeout, metadata=metadata,)
3075+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
30623076

30633077
# Done; return the response.
30643078
return response
@@ -3092,9 +3106,11 @@ async def get_location(
30923106
# The request isn't a proto-plus wrapped type,
30933107
# so it must be constructed via keyword expansion.
30943108
if request is None:
3095-
request = {}
3096-
if isinstance(request, dict):
3097-
request = locations_pb2.GetLocationRequest(**request)
3109+
request_pb = locations_pb2.GetLocationRequest()
3110+
elif isinstance(request, dict):
3111+
request_pb = locations_pb2.GetLocationRequest(**request)
3112+
else:
3113+
request_pb = request
30983114

30993115
# Wrap the RPC method; this adds retry and timeout information,
31003116
# and friendly error handling.
@@ -3104,15 +3120,15 @@ async def get_location(
31043120
# add these here.
31053121
metadata = tuple(metadata) + (
31063122
gapic_v1.routing_header.to_grpc_metadata(
3107-
(("name", request.name),)),
3123+
(("name", request_pb.name),)),
31083124
)
31093125

31103126
# Validate the universe domain.
31113127
self._client._validate_universe_domain()
31123128

31133129
# Send the request.
31143130
response = await rpc(
3115-
request, retry=retry, timeout=timeout, metadata=metadata,)
3131+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
31163132

31173133
# Done; return the response.
31183134
return response
@@ -3146,9 +3162,11 @@ async def list_locations(
31463162
# The request isn't a proto-plus wrapped type,
31473163
# so it must be constructed via keyword expansion.
31483164
if request is None:
3149-
request = {}
3150-
if isinstance(request, dict):
3151-
request = locations_pb2.ListLocationsRequest(**request)
3165+
request_pb = locations_pb2.ListLocationsRequest()
3166+
elif isinstance(request, dict):
3167+
request_pb = locations_pb2.ListLocationsRequest(**request)
3168+
else:
3169+
request_pb = request
31523170

31533171
# Wrap the RPC method; this adds retry and timeout information,
31543172
# and friendly error handling.
@@ -3158,15 +3176,15 @@ async def list_locations(
31583176
# add these here.
31593177
metadata = tuple(metadata) + (
31603178
gapic_v1.routing_header.to_grpc_metadata(
3161-
(("name", request.name),)),
3179+
(("name", request_pb.name),)),
31623180
)
31633181

31643182
# Validate the universe domain.
31653183
self._client._validate_universe_domain()
31663184

31673185
# Send the request.
31683186
response = await rpc(
3169-
request, retry=retry, timeout=timeout, metadata=metadata,)
3187+
request_pb, retry=retry, timeout=timeout, metadata=metadata,)
31703188

31713189
# Done; return the response.
31723190
return response

0 commit comments

Comments
 (0)