@@ -2663,11 +2663,7 @@ async def list_operations(
2663
2663
2664
2664
# Wrap the RPC method; this adds retry and timeout information,
2665
2665
# and friendly error handling.
2666
- rpc = gapic_v1 .method_async .wrap_method (
2667
- self ._client ._transport .list_operations ,
2668
- default_timeout = None ,
2669
- client_info = DEFAULT_CLIENT_INFO ,
2670
- )
2666
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .list_operations ]
2671
2667
2672
2668
# Certain fields should be provided within the metadata header;
2673
2669
# add these here.
@@ -2720,11 +2716,7 @@ async def get_operation(
2720
2716
2721
2717
# Wrap the RPC method; this adds retry and timeout information,
2722
2718
# and friendly error handling.
2723
- rpc = gapic_v1 .method_async .wrap_method (
2724
- self ._client ._transport .get_operation ,
2725
- default_timeout = None ,
2726
- client_info = DEFAULT_CLIENT_INFO ,
2727
- )
2719
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .get_operation ]
2728
2720
2729
2721
# Certain fields should be provided within the metadata header;
2730
2722
# add these here.
@@ -2781,11 +2773,7 @@ async def delete_operation(
2781
2773
2782
2774
# Wrap the RPC method; this adds retry and timeout information,
2783
2775
# and friendly error handling.
2784
- rpc = gapic_v1 .method_async .wrap_method (
2785
- self ._client ._transport .delete_operation ,
2786
- default_timeout = None ,
2787
- client_info = DEFAULT_CLIENT_INFO ,
2788
- )
2776
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .delete_operation ]
2789
2777
2790
2778
# Certain fields should be provided within the metadata header;
2791
2779
# add these here.
@@ -2838,11 +2826,7 @@ async def cancel_operation(
2838
2826
2839
2827
# Wrap the RPC method; this adds retry and timeout information,
2840
2828
# and friendly error handling.
2841
- rpc = gapic_v1 .method_async .wrap_method (
2842
- self ._client ._transport .cancel_operation ,
2843
- default_timeout = None ,
2844
- client_info = DEFAULT_CLIENT_INFO ,
2845
- )
2829
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .cancel_operation ]
2846
2830
2847
2831
# Certain fields should be provided within the metadata header;
2848
2832
# add these here.
@@ -2898,11 +2882,7 @@ async def wait_operation(
2898
2882
2899
2883
# Wrap the RPC method; this adds retry and timeout information,
2900
2884
# and friendly error handling.
2901
- rpc = gapic_v1 .method_async .wrap_method (
2902
- self ._client ._transport .wait_operation ,
2903
- default_timeout = None ,
2904
- client_info = DEFAULT_CLIENT_INFO ,
2905
- )
2885
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .wait_operation ]
2906
2886
2907
2887
# Certain fields should be provided within the metadata header;
2908
2888
# add these here.
@@ -3021,11 +3001,7 @@ async def set_iam_policy(
3021
3001
3022
3002
# Wrap the RPC method; this adds retry and timeout information,
3023
3003
# and friendly error handling.
3024
- rpc = gapic_v1 .method_async .wrap_method (
3025
- self ._client ._transport .set_iam_policy ,
3026
- default_timeout = None ,
3027
- client_info = DEFAULT_CLIENT_INFO ,
3028
- )
3004
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .set_iam_policy ]
3029
3005
3030
3006
# Certain fields should be provided within the metadata header;
3031
3007
# add these here.
@@ -3145,11 +3121,7 @@ async def get_iam_policy(
3145
3121
3146
3122
# Wrap the RPC method; this adds retry and timeout information,
3147
3123
# and friendly error handling.
3148
- rpc = gapic_v1 .method_async .wrap_method (
3149
- self ._client ._transport .get_iam_policy ,
3150
- default_timeout = None ,
3151
- client_info = DEFAULT_CLIENT_INFO ,
3152
- )
3124
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .get_iam_policy ]
3153
3125
3154
3126
# Certain fields should be provided within the metadata header;
3155
3127
# add these here.
@@ -3207,11 +3179,9 @@ async def test_iam_permissions(
3207
3179
3208
3180
# Wrap the RPC method; this adds retry and timeout information,
3209
3181
# and friendly error handling.
3210
- rpc = gapic_v1 .method_async .wrap_method (
3211
- self ._client ._transport .test_iam_permissions ,
3212
- default_timeout = None ,
3213
- client_info = DEFAULT_CLIENT_INFO ,
3214
- )
3182
+ rpc = self .transport ._wrapped_methods [
3183
+ self ._client ._transport .test_iam_permissions
3184
+ ]
3215
3185
3216
3186
# Certain fields should be provided within the metadata header;
3217
3187
# add these here.
@@ -3264,11 +3234,7 @@ async def get_location(
3264
3234
3265
3235
# Wrap the RPC method; this adds retry and timeout information,
3266
3236
# and friendly error handling.
3267
- rpc = gapic_v1 .method_async .wrap_method (
3268
- self ._client ._transport .get_location ,
3269
- default_timeout = None ,
3270
- client_info = DEFAULT_CLIENT_INFO ,
3271
- )
3237
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .get_location ]
3272
3238
3273
3239
# Certain fields should be provided within the metadata header;
3274
3240
# add these here.
@@ -3321,11 +3287,7 @@ async def list_locations(
3321
3287
3322
3288
# Wrap the RPC method; this adds retry and timeout information,
3323
3289
# and friendly error handling.
3324
- rpc = gapic_v1 .method_async .wrap_method (
3325
- self ._client ._transport .list_locations ,
3326
- default_timeout = None ,
3327
- client_info = DEFAULT_CLIENT_INFO ,
3328
- )
3290
+ rpc = self .transport ._wrapped_methods [self ._client ._transport .list_locations ]
3329
3291
3330
3292
# Certain fields should be provided within the metadata header;
3331
3293
# add these here.
0 commit comments