1313# See the License for the specific language governing permissions and
1414# limitations under the License.
1515#
16+ from google .api_core import gapic_v1
17+ from google .api_core import retry as retries
18+ from google .api_core import retry_async as retries_async
1619from typing import (
1720 Any ,
1821 AsyncIterator ,
2225 Tuple ,
2326 Optional ,
2427 Iterator ,
28+ Union ,
2529)
2630
31+ try :
32+ OptionalRetry = Union [retries .Retry , gapic_v1 .method ._MethodDefault , None ]
33+ OptionalAsyncRetry = Union [
34+ retries_async .AsyncRetry , gapic_v1 .method ._MethodDefault , None
35+ ]
36+ except AttributeError : # pragma: NO COVER
37+ OptionalRetry = Union [retries .Retry , object , None ] # type: ignore
38+ OptionalAsyncRetry = Union [retries_async .AsyncRetry , object , None ] # type: ignore
39+
2740from google .cloud .bigtable_admin_v2 .types import bigtable_instance_admin
2841from google .cloud .bigtable_admin_v2 .types import instance
2942
@@ -52,6 +65,8 @@ def __init__(
5265 request : bigtable_instance_admin .ListAppProfilesRequest ,
5366 response : bigtable_instance_admin .ListAppProfilesResponse ,
5467 * ,
68+ retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
69+ timeout : Union [float , object ] = gapic_v1 .method .DEFAULT ,
5570 metadata : Sequence [Tuple [str , str ]] = ()
5671 ):
5772 """Instantiate the pager.
@@ -63,12 +78,17 @@ def __init__(
6378 The initial request object.
6479 response (google.cloud.bigtable_admin_v2.types.ListAppProfilesResponse):
6580 The initial response object.
81+ retry (google.api_core.retry.Retry): Designation of what errors,
82+ if any, should be retried.
83+ timeout (float): The timeout for this request.
6684 metadata (Sequence[Tuple[str, str]]): Strings which should be
6785 sent along with the request as metadata.
6886 """
6987 self ._method = method
7088 self ._request = bigtable_instance_admin .ListAppProfilesRequest (request )
7189 self ._response = response
90+ self ._retry = retry
91+ self ._timeout = timeout
7292 self ._metadata = metadata
7393
7494 def __getattr__ (self , name : str ) -> Any :
@@ -79,7 +99,12 @@ def pages(self) -> Iterator[bigtable_instance_admin.ListAppProfilesResponse]:
7999 yield self ._response
80100 while self ._response .next_page_token :
81101 self ._request .page_token = self ._response .next_page_token
82- self ._response = self ._method (self ._request , metadata = self ._metadata )
102+ self ._response = self ._method (
103+ self ._request ,
104+ retry = self ._retry ,
105+ timeout = self ._timeout ,
106+ metadata = self ._metadata ,
107+ )
83108 yield self ._response
84109
85110 def __iter__ (self ) -> Iterator [instance .AppProfile ]:
@@ -116,6 +141,8 @@ def __init__(
116141 request : bigtable_instance_admin .ListAppProfilesRequest ,
117142 response : bigtable_instance_admin .ListAppProfilesResponse ,
118143 * ,
144+ retry : OptionalAsyncRetry = gapic_v1 .method .DEFAULT ,
145+ timeout : Union [float , object ] = gapic_v1 .method .DEFAULT ,
119146 metadata : Sequence [Tuple [str , str ]] = ()
120147 ):
121148 """Instantiates the pager.
@@ -127,12 +154,17 @@ def __init__(
127154 The initial request object.
128155 response (google.cloud.bigtable_admin_v2.types.ListAppProfilesResponse):
129156 The initial response object.
157+ retry (google.api_core.retry.AsyncRetry): Designation of what errors,
158+ if any, should be retried.
159+ timeout (float): The timeout for this request.
130160 metadata (Sequence[Tuple[str, str]]): Strings which should be
131161 sent along with the request as metadata.
132162 """
133163 self ._method = method
134164 self ._request = bigtable_instance_admin .ListAppProfilesRequest (request )
135165 self ._response = response
166+ self ._retry = retry
167+ self ._timeout = timeout
136168 self ._metadata = metadata
137169
138170 def __getattr__ (self , name : str ) -> Any :
@@ -145,7 +177,12 @@ async def pages(
145177 yield self ._response
146178 while self ._response .next_page_token :
147179 self ._request .page_token = self ._response .next_page_token
148- self ._response = await self ._method (self ._request , metadata = self ._metadata )
180+ self ._response = await self ._method (
181+ self ._request ,
182+ retry = self ._retry ,
183+ timeout = self ._timeout ,
184+ metadata = self ._metadata ,
185+ )
149186 yield self ._response
150187
151188 def __aiter__ (self ) -> AsyncIterator [instance .AppProfile ]:
@@ -184,6 +221,8 @@ def __init__(
184221 request : bigtable_instance_admin .ListHotTabletsRequest ,
185222 response : bigtable_instance_admin .ListHotTabletsResponse ,
186223 * ,
224+ retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
225+ timeout : Union [float , object ] = gapic_v1 .method .DEFAULT ,
187226 metadata : Sequence [Tuple [str , str ]] = ()
188227 ):
189228 """Instantiate the pager.
@@ -195,12 +234,17 @@ def __init__(
195234 The initial request object.
196235 response (google.cloud.bigtable_admin_v2.types.ListHotTabletsResponse):
197236 The initial response object.
237+ retry (google.api_core.retry.Retry): Designation of what errors,
238+ if any, should be retried.
239+ timeout (float): The timeout for this request.
198240 metadata (Sequence[Tuple[str, str]]): Strings which should be
199241 sent along with the request as metadata.
200242 """
201243 self ._method = method
202244 self ._request = bigtable_instance_admin .ListHotTabletsRequest (request )
203245 self ._response = response
246+ self ._retry = retry
247+ self ._timeout = timeout
204248 self ._metadata = metadata
205249
206250 def __getattr__ (self , name : str ) -> Any :
@@ -211,7 +255,12 @@ def pages(self) -> Iterator[bigtable_instance_admin.ListHotTabletsResponse]:
211255 yield self ._response
212256 while self ._response .next_page_token :
213257 self ._request .page_token = self ._response .next_page_token
214- self ._response = self ._method (self ._request , metadata = self ._metadata )
258+ self ._response = self ._method (
259+ self ._request ,
260+ retry = self ._retry ,
261+ timeout = self ._timeout ,
262+ metadata = self ._metadata ,
263+ )
215264 yield self ._response
216265
217266 def __iter__ (self ) -> Iterator [instance .HotTablet ]:
@@ -248,6 +297,8 @@ def __init__(
248297 request : bigtable_instance_admin .ListHotTabletsRequest ,
249298 response : bigtable_instance_admin .ListHotTabletsResponse ,
250299 * ,
300+ retry : OptionalAsyncRetry = gapic_v1 .method .DEFAULT ,
301+ timeout : Union [float , object ] = gapic_v1 .method .DEFAULT ,
251302 metadata : Sequence [Tuple [str , str ]] = ()
252303 ):
253304 """Instantiates the pager.
@@ -259,12 +310,17 @@ def __init__(
259310 The initial request object.
260311 response (google.cloud.bigtable_admin_v2.types.ListHotTabletsResponse):
261312 The initial response object.
313+ retry (google.api_core.retry.AsyncRetry): Designation of what errors,
314+ if any, should be retried.
315+ timeout (float): The timeout for this request.
262316 metadata (Sequence[Tuple[str, str]]): Strings which should be
263317 sent along with the request as metadata.
264318 """
265319 self ._method = method
266320 self ._request = bigtable_instance_admin .ListHotTabletsRequest (request )
267321 self ._response = response
322+ self ._retry = retry
323+ self ._timeout = timeout
268324 self ._metadata = metadata
269325
270326 def __getattr__ (self , name : str ) -> Any :
@@ -277,7 +333,12 @@ async def pages(
277333 yield self ._response
278334 while self ._response .next_page_token :
279335 self ._request .page_token = self ._response .next_page_token
280- self ._response = await self ._method (self ._request , metadata = self ._metadata )
336+ self ._response = await self ._method (
337+ self ._request ,
338+ retry = self ._retry ,
339+ timeout = self ._timeout ,
340+ metadata = self ._metadata ,
341+ )
281342 yield self ._response
282343
283344 def __aiter__ (self ) -> AsyncIterator [instance .HotTablet ]:
0 commit comments