Skip to content

Commit a6f7356

Browse files
chore: [Many APIs] Update gapic-generator-python to v1.18.4 (#12950)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 657207628 Source-Link: googleapis/googleapis@33fe71e Source-Link: googleapis/googleapis-gen@e02739d Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LW1pZ3JhdGlvbi8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LXJlc2VydmF0aW9uLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbGxpbmctYnVkZ2V0cy8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbGxpbmcvLk93bEJvdC55YW1sIiwiaCI6ImUwMjczOWQxMjJlZDE1YmQ1ZWY1NzcxYzU3ZjEyYTgzZDQ3YTFkZGEifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbmFyeS1hdXRob3JpemF0aW9uLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJ1aWxkLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNlcnRpZmljYXRlLW1hbmFnZXIvLk93bEJvdC55YW1sIiwiaCI6ImUwMjczOWQxMjJlZDE1YmQ1ZWY1NzcxYzU3ZjEyYTgzZDQ3YTFkZGEifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNoYW5uZWwvLk93bEJvdC55YW1sIiwiaCI6ImUwMjczOWQxMjJlZDE1YmQ1ZWY1NzcxYzU3ZjEyYTgzZDQ3YTFkZGEifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNsb3VkY29udHJvbHNwYXJ0bmVyLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNsb3VkcXVvdGFzLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbW1lcmNlLWNvbnN1bWVyLXByb2N1cmVtZW50Ly5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbW1vbi8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbXB1dGUvLk93bEJvdC55YW1sIiwiaCI6ImUwMjczOWQxMjJlZDE1YmQ1ZWY1NzcxYzU3ZjEyYTgzZDQ3YTFkZGEifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbmZpZGVudGlhbGNvbXB1dGluZy8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbmZpZy8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhY3QtY2VudGVyLWluc2lnaHRzLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhaW5lci8uT3dsQm90LnlhbWwiLCJoIjoiZTAyNzM5ZDEyMmVkMTViZDVlZjU3NzFjNTdmMTJhODNkNDdhMWRkYSJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhaW5lcmFuYWx5c2lzLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRlbnR3YXJlaG91c2UvLk93bEJvdC55YW1sIiwiaCI6ImUwMjczOWQxMjJlZDE1YmQ1ZWY1NzcxYzU3ZjEyYTgzZDQ3YTFkZGEifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWRhdGEtZnVzaW9uLy5Pd2xCb3QueWFtbCIsImgiOiJlMDI3MzlkMTIyZWQxNWJkNWVmNTc3MWM1N2YxMmE4M2Q0N2ExZGRhIn0= --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 6e83a37 commit a6f7356

File tree

477 files changed

+6999
-449
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

477 files changed

+6999
-449
lines changed

packages/google-cloud-bigquery-migration/google/cloud/bigquery_migration_v2/services/migration_service/async_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -620,6 +620,8 @@ async def sample_list_migration_workflows():
620620
method=rpc,
621621
request=request,
622622
response=response,
623+
retry=retry,
624+
timeout=timeout,
623625
metadata=metadata,
624626
)
625627

@@ -1051,6 +1053,8 @@ async def sample_list_migration_subtasks():
10511053
method=rpc,
10521054
request=request,
10531055
response=response,
1056+
retry=retry,
1057+
timeout=timeout,
10541058
metadata=metadata,
10551059
)
10561060

packages/google-cloud-bigquery-migration/google/cloud/bigquery_migration_v2/services/migration_service/client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1048,6 +1048,8 @@ def sample_list_migration_workflows():
10481048
method=rpc,
10491049
request=request,
10501050
response=response,
1051+
retry=retry,
1052+
timeout=timeout,
10511053
metadata=metadata,
10521054
)
10531055

@@ -1469,6 +1471,8 @@ def sample_list_migration_subtasks():
14691471
method=rpc,
14701472
request=request,
14711473
response=response,
1474+
retry=retry,
1475+
timeout=timeout,
14721476
metadata=metadata,
14731477
)
14741478

packages/google-cloud-bigquery-migration/google/cloud/bigquery_migration_v2/services/migration_service/pagers.py

Lines changed: 66 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,22 @@
2222
Optional,
2323
Sequence,
2424
Tuple,
25+
Union,
2526
)
2627

28+
from google.api_core import gapic_v1
29+
from google.api_core import retry as retries
30+
from google.api_core import retry_async as retries_async
31+
32+
try:
33+
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault, None]
34+
OptionalAsyncRetry = Union[
35+
retries_async.AsyncRetry, gapic_v1.method._MethodDefault, None
36+
]
37+
except AttributeError: # pragma: NO COVER
38+
OptionalRetry = Union[retries.Retry, object, None] # type: ignore
39+
OptionalAsyncRetry = Union[retries_async.AsyncRetry, object, None] # type: ignore
40+
2741
from google.cloud.bigquery_migration_v2.types import (
2842
migration_entities,
2943
migration_service,
@@ -54,6 +68,8 @@ def __init__(
5468
request: migration_service.ListMigrationWorkflowsRequest,
5569
response: migration_service.ListMigrationWorkflowsResponse,
5670
*,
71+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
72+
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
5773
metadata: Sequence[Tuple[str, str]] = ()
5874
):
5975
"""Instantiate the pager.
@@ -65,12 +81,17 @@ def __init__(
6581
The initial request object.
6682
response (google.cloud.bigquery_migration_v2.types.ListMigrationWorkflowsResponse):
6783
The initial response object.
84+
retry (google.api_core.retry.Retry): Designation of what errors,
85+
if any, should be retried.
86+
timeout (float): The timeout for this request.
6887
metadata (Sequence[Tuple[str, str]]): Strings which should be
6988
sent along with the request as metadata.
7089
"""
7190
self._method = method
7291
self._request = migration_service.ListMigrationWorkflowsRequest(request)
7392
self._response = response
93+
self._retry = retry
94+
self._timeout = timeout
7495
self._metadata = metadata
7596

7697
def __getattr__(self, name: str) -> Any:
@@ -81,7 +102,12 @@ def pages(self) -> Iterator[migration_service.ListMigrationWorkflowsResponse]:
81102
yield self._response
82103
while self._response.next_page_token:
83104
self._request.page_token = self._response.next_page_token
84-
self._response = self._method(self._request, metadata=self._metadata)
105+
self._response = self._method(
106+
self._request,
107+
retry=self._retry,
108+
timeout=self._timeout,
109+
metadata=self._metadata,
110+
)
85111
yield self._response
86112

87113
def __iter__(self) -> Iterator[migration_entities.MigrationWorkflow]:
@@ -118,6 +144,8 @@ def __init__(
118144
request: migration_service.ListMigrationWorkflowsRequest,
119145
response: migration_service.ListMigrationWorkflowsResponse,
120146
*,
147+
retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
148+
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
121149
metadata: Sequence[Tuple[str, str]] = ()
122150
):
123151
"""Instantiates the pager.
@@ -129,12 +157,17 @@ def __init__(
129157
The initial request object.
130158
response (google.cloud.bigquery_migration_v2.types.ListMigrationWorkflowsResponse):
131159
The initial response object.
160+
retry (google.api_core.retry.AsyncRetry): Designation of what errors,
161+
if any, should be retried.
162+
timeout (float): The timeout for this request.
132163
metadata (Sequence[Tuple[str, str]]): Strings which should be
133164
sent along with the request as metadata.
134165
"""
135166
self._method = method
136167
self._request = migration_service.ListMigrationWorkflowsRequest(request)
137168
self._response = response
169+
self._retry = retry
170+
self._timeout = timeout
138171
self._metadata = metadata
139172

140173
def __getattr__(self, name: str) -> Any:
@@ -147,7 +180,12 @@ async def pages(
147180
yield self._response
148181
while self._response.next_page_token:
149182
self._request.page_token = self._response.next_page_token
150-
self._response = await self._method(self._request, metadata=self._metadata)
183+
self._response = await self._method(
184+
self._request,
185+
retry=self._retry,
186+
timeout=self._timeout,
187+
metadata=self._metadata,
188+
)
151189
yield self._response
152190

153191
def __aiter__(self) -> AsyncIterator[migration_entities.MigrationWorkflow]:
@@ -186,6 +224,8 @@ def __init__(
186224
request: migration_service.ListMigrationSubtasksRequest,
187225
response: migration_service.ListMigrationSubtasksResponse,
188226
*,
227+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
228+
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
189229
metadata: Sequence[Tuple[str, str]] = ()
190230
):
191231
"""Instantiate the pager.
@@ -197,12 +237,17 @@ def __init__(
197237
The initial request object.
198238
response (google.cloud.bigquery_migration_v2.types.ListMigrationSubtasksResponse):
199239
The initial response object.
240+
retry (google.api_core.retry.Retry): Designation of what errors,
241+
if any, should be retried.
242+
timeout (float): The timeout for this request.
200243
metadata (Sequence[Tuple[str, str]]): Strings which should be
201244
sent along with the request as metadata.
202245
"""
203246
self._method = method
204247
self._request = migration_service.ListMigrationSubtasksRequest(request)
205248
self._response = response
249+
self._retry = retry
250+
self._timeout = timeout
206251
self._metadata = metadata
207252

208253
def __getattr__(self, name: str) -> Any:
@@ -213,7 +258,12 @@ def pages(self) -> Iterator[migration_service.ListMigrationSubtasksResponse]:
213258
yield self._response
214259
while self._response.next_page_token:
215260
self._request.page_token = self._response.next_page_token
216-
self._response = self._method(self._request, metadata=self._metadata)
261+
self._response = self._method(
262+
self._request,
263+
retry=self._retry,
264+
timeout=self._timeout,
265+
metadata=self._metadata,
266+
)
217267
yield self._response
218268

219269
def __iter__(self) -> Iterator[migration_entities.MigrationSubtask]:
@@ -250,6 +300,8 @@ def __init__(
250300
request: migration_service.ListMigrationSubtasksRequest,
251301
response: migration_service.ListMigrationSubtasksResponse,
252302
*,
303+
retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
304+
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
253305
metadata: Sequence[Tuple[str, str]] = ()
254306
):
255307
"""Instantiates the pager.
@@ -261,12 +313,17 @@ def __init__(
261313
The initial request object.
262314
response (google.cloud.bigquery_migration_v2.types.ListMigrationSubtasksResponse):
263315
The initial response object.
316+
retry (google.api_core.retry.AsyncRetry): Designation of what errors,
317+
if any, should be retried.
318+
timeout (float): The timeout for this request.
264319
metadata (Sequence[Tuple[str, str]]): Strings which should be
265320
sent along with the request as metadata.
266321
"""
267322
self._method = method
268323
self._request = migration_service.ListMigrationSubtasksRequest(request)
269324
self._response = response
325+
self._retry = retry
326+
self._timeout = timeout
270327
self._metadata = metadata
271328

272329
def __getattr__(self, name: str) -> Any:
@@ -279,7 +336,12 @@ async def pages(
279336
yield self._response
280337
while self._response.next_page_token:
281338
self._request.page_token = self._response.next_page_token
282-
self._response = await self._method(self._request, metadata=self._metadata)
339+
self._response = await self._method(
340+
self._request,
341+
retry=self._retry,
342+
timeout=self._timeout,
343+
metadata=self._metadata,
344+
)
283345
yield self._response
284346

285347
def __aiter__(self) -> AsyncIterator[migration_entities.MigrationSubtask]:

packages/google-cloud-bigquery-migration/google/cloud/bigquery_migration_v2alpha/services/migration_service/async_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -620,6 +620,8 @@ async def sample_list_migration_workflows():
620620
method=rpc,
621621
request=request,
622622
response=response,
623+
retry=retry,
624+
timeout=timeout,
623625
metadata=metadata,
624626
)
625627

@@ -1051,6 +1053,8 @@ async def sample_list_migration_subtasks():
10511053
method=rpc,
10521054
request=request,
10531055
response=response,
1056+
retry=retry,
1057+
timeout=timeout,
10541058
metadata=metadata,
10551059
)
10561060

packages/google-cloud-bigquery-migration/google/cloud/bigquery_migration_v2alpha/services/migration_service/client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1048,6 +1048,8 @@ def sample_list_migration_workflows():
10481048
method=rpc,
10491049
request=request,
10501050
response=response,
1051+
retry=retry,
1052+
timeout=timeout,
10511053
metadata=metadata,
10521054
)
10531055

@@ -1469,6 +1471,8 @@ def sample_list_migration_subtasks():
14691471
method=rpc,
14701472
request=request,
14711473
response=response,
1474+
retry=retry,
1475+
timeout=timeout,
14721476
metadata=metadata,
14731477
)
14741478

0 commit comments

Comments
 (0)