1616from collections import OrderedDict
1717import functools
1818import re
19- from typing import Dict , Mapping , Optional , Sequence , Tuple , Type , Union
19+ from typing import (
20+ Dict ,
21+ Mapping ,
22+ MutableMapping ,
23+ MutableSequence ,
24+ Optional ,
25+ Sequence ,
26+ Tuple ,
27+ Type ,
28+ Union ,
29+ )
2030
2131from google .api_core import exceptions as core_exceptions
2232from google .api_core import gapic_v1
@@ -164,9 +174,9 @@ def transport(self) -> ConnectionServiceTransport:
164174 def __init__ (
165175 self ,
166176 * ,
167- credentials : ga_credentials .Credentials = None ,
177+ credentials : Optional [ ga_credentials .Credentials ] = None ,
168178 transport : Union [str , ConnectionServiceTransport ] = "grpc_asyncio" ,
169- client_options : ClientOptions = None ,
179+ client_options : Optional [ ClientOptions ] = None ,
170180 client_info : gapic_v1 .client_info .ClientInfo = DEFAULT_CLIENT_INFO ,
171181 ) -> None :
172182 """Instantiates the connection service client.
@@ -210,13 +220,13 @@ def __init__(
210220
211221 async def create_connection (
212222 self ,
213- request : Union [gcbc_connection .CreateConnectionRequest , dict ] = None ,
223+ request : Optional [ Union [gcbc_connection .CreateConnectionRequest , dict ] ] = None ,
214224 * ,
215- parent : str = None ,
216- connection : gcbc_connection .Connection = None ,
217- connection_id : str = None ,
225+ parent : Optional [ str ] = None ,
226+ connection : Optional [ gcbc_connection .Connection ] = None ,
227+ connection_id : Optional [ str ] = None ,
218228 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
219- timeout : float = None ,
229+ timeout : Optional [ float ] = None ,
220230 metadata : Sequence [Tuple [str , str ]] = (),
221231 ) -> gcbc_connection .Connection :
222232 r"""Creates a new connection.
@@ -248,7 +258,7 @@ async def sample_create_connection():
248258 print(response)
249259
250260 Args:
251- request (Union[google.cloud.bigquery_connection_v1.types.CreateConnectionRequest, dict]):
261+ request (Optional[ Union[google.cloud.bigquery_connection_v1.types.CreateConnectionRequest, dict] ]):
252262 The request object. The request for
253263 [ConnectionService.CreateConnection][google.cloud.bigquery.connection.v1.ConnectionService.CreateConnection].
254264 parent (:class:`str`):
@@ -331,11 +341,11 @@ async def sample_create_connection():
331341
332342 async def get_connection (
333343 self ,
334- request : Union [connection .GetConnectionRequest , dict ] = None ,
344+ request : Optional [ Union [connection .GetConnectionRequest , dict ] ] = None ,
335345 * ,
336- name : str = None ,
346+ name : Optional [ str ] = None ,
337347 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
338- timeout : float = None ,
348+ timeout : Optional [ float ] = None ,
339349 metadata : Sequence [Tuple [str , str ]] = (),
340350 ) -> connection .Connection :
341351 r"""Returns specified connection.
@@ -367,7 +377,7 @@ async def sample_get_connection():
367377 print(response)
368378
369379 Args:
370- request (Union[google.cloud.bigquery_connection_v1.types.GetConnectionRequest, dict]):
380+ request (Optional[ Union[google.cloud.bigquery_connection_v1.types.GetConnectionRequest, dict] ]):
371381 The request object. The request for
372382 [ConnectionService.GetConnection][google.cloud.bigquery.connection.v1.ConnectionService.GetConnection].
373383 name (:class:`str`):
@@ -444,11 +454,11 @@ async def sample_get_connection():
444454
445455 async def list_connections (
446456 self ,
447- request : Union [connection .ListConnectionsRequest , dict ] = None ,
457+ request : Optional [ Union [connection .ListConnectionsRequest , dict ] ] = None ,
448458 * ,
449- parent : str = None ,
459+ parent : Optional [ str ] = None ,
450460 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
451- timeout : float = None ,
461+ timeout : Optional [ float ] = None ,
452462 metadata : Sequence [Tuple [str , str ]] = (),
453463 ) -> pagers .ListConnectionsAsyncPager :
454464 r"""Returns a list of connections in the given project.
@@ -482,7 +492,7 @@ async def sample_list_connections():
482492 print(response)
483493
484494 Args:
485- request (Union[google.cloud.bigquery_connection_v1.types.ListConnectionsRequest, dict]):
495+ request (Optional[ Union[google.cloud.bigquery_connection_v1.types.ListConnectionsRequest, dict] ]):
486496 The request object. The request for
487497 [ConnectionService.ListConnections][google.cloud.bigquery.connection.v1.ConnectionService.ListConnections].
488498 parent (:class:`str`):
@@ -570,13 +580,13 @@ async def sample_list_connections():
570580
571581 async def update_connection (
572582 self ,
573- request : Union [gcbc_connection .UpdateConnectionRequest , dict ] = None ,
583+ request : Optional [ Union [gcbc_connection .UpdateConnectionRequest , dict ] ] = None ,
574584 * ,
575- name : str = None ,
576- connection : gcbc_connection .Connection = None ,
577- update_mask : field_mask_pb2 .FieldMask = None ,
585+ name : Optional [ str ] = None ,
586+ connection : Optional [ gcbc_connection .Connection ] = None ,
587+ update_mask : Optional [ field_mask_pb2 .FieldMask ] = None ,
578588 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
579- timeout : float = None ,
589+ timeout : Optional [ float ] = None ,
580590 metadata : Sequence [Tuple [str , str ]] = (),
581591 ) -> gcbc_connection .Connection :
582592 r"""Updates the specified connection. For security
@@ -610,7 +620,7 @@ async def sample_update_connection():
610620 print(response)
611621
612622 Args:
613- request (Union[google.cloud.bigquery_connection_v1.types.UpdateConnectionRequest, dict]):
623+ request (Optional[ Union[google.cloud.bigquery_connection_v1.types.UpdateConnectionRequest, dict] ]):
614624 The request object. The request for
615625 [ConnectionService.UpdateConnection][google.cloud.bigquery.connection.v1.ConnectionService.UpdateConnection].
616626 name (:class:`str`):
@@ -695,11 +705,11 @@ async def sample_update_connection():
695705
696706 async def delete_connection (
697707 self ,
698- request : Union [connection .DeleteConnectionRequest , dict ] = None ,
708+ request : Optional [ Union [connection .DeleteConnectionRequest , dict ] ] = None ,
699709 * ,
700- name : str = None ,
710+ name : Optional [ str ] = None ,
701711 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
702- timeout : float = None ,
712+ timeout : Optional [ float ] = None ,
703713 metadata : Sequence [Tuple [str , str ]] = (),
704714 ) -> None :
705715 r"""Deletes connection and associated credential.
@@ -728,7 +738,7 @@ async def sample_delete_connection():
728738 await client.delete_connection(request=request)
729739
730740 Args:
731- request (Union[google.cloud.bigquery_connection_v1.types.DeleteConnectionRequest, dict]):
741+ request (Optional[ Union[google.cloud.bigquery_connection_v1.types.DeleteConnectionRequest, dict] ]):
732742 The request object. The request for
733743 [ConnectionService.DeleteConnectionRequest][].
734744 name (:class:`str`):
@@ -795,11 +805,11 @@ async def sample_delete_connection():
795805
796806 async def get_iam_policy (
797807 self ,
798- request : Union [iam_policy_pb2 .GetIamPolicyRequest , dict ] = None ,
808+ request : Optional [ Union [iam_policy_pb2 .GetIamPolicyRequest , dict ] ] = None ,
799809 * ,
800- resource : str = None ,
810+ resource : Optional [ str ] = None ,
801811 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
802- timeout : float = None ,
812+ timeout : Optional [ float ] = None ,
803813 metadata : Sequence [Tuple [str , str ]] = (),
804814 ) -> policy_pb2 .Policy :
805815 r"""Gets the access control policy for a resource.
@@ -834,7 +844,7 @@ async def sample_get_iam_policy():
834844 print(response)
835845
836846 Args:
837- request (Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]):
847+ request (Optional[ Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict] ]):
838848 The request object. Request message for `GetIamPolicy`
839849 method.
840850 resource (:class:`str`):
@@ -963,11 +973,11 @@ async def sample_get_iam_policy():
963973
964974 async def set_iam_policy (
965975 self ,
966- request : Union [iam_policy_pb2 .SetIamPolicyRequest , dict ] = None ,
976+ request : Optional [ Union [iam_policy_pb2 .SetIamPolicyRequest , dict ] ] = None ,
967977 * ,
968- resource : str = None ,
978+ resource : Optional [ str ] = None ,
969979 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
970- timeout : float = None ,
980+ timeout : Optional [ float ] = None ,
971981 metadata : Sequence [Tuple [str , str ]] = (),
972982 ) -> policy_pb2 .Policy :
973983 r"""Sets the access control policy on the specified resource.
@@ -1004,7 +1014,7 @@ async def sample_set_iam_policy():
10041014 print(response)
10051015
10061016 Args:
1007- request (Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]):
1017+ request (Optional[ Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict] ]):
10081018 The request object. Request message for `SetIamPolicy`
10091019 method.
10101020 resource (:class:`str`):
@@ -1133,12 +1143,12 @@ async def sample_set_iam_policy():
11331143
11341144 async def test_iam_permissions (
11351145 self ,
1136- request : Union [iam_policy_pb2 .TestIamPermissionsRequest , dict ] = None ,
1146+ request : Optional [ Union [iam_policy_pb2 .TestIamPermissionsRequest , dict ] ] = None ,
11371147 * ,
1138- resource : str = None ,
1139- permissions : Sequence [ str ] = None ,
1148+ resource : Optional [ str ] = None ,
1149+ permissions : Optional [ MutableSequence [ str ] ] = None ,
11401150 retry : OptionalRetry = gapic_v1 .method .DEFAULT ,
1141- timeout : float = None ,
1151+ timeout : Optional [ float ] = None ,
11421152 metadata : Sequence [Tuple [str , str ]] = (),
11431153 ) -> iam_policy_pb2 .TestIamPermissionsResponse :
11441154 r"""Returns permissions that a caller has on the specified resource.
@@ -1179,7 +1189,7 @@ async def sample_test_iam_permissions():
11791189 print(response)
11801190
11811191 Args:
1182- request (Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]):
1192+ request (Optional[ Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict] ]):
11831193 The request object. Request message for
11841194 `TestIamPermissions` method.
11851195 resource (:class:`str`):
@@ -1191,7 +1201,7 @@ async def sample_test_iam_permissions():
11911201 This corresponds to the ``resource`` field
11921202 on the ``request`` instance; if ``request`` is provided, this
11931203 should not be set.
1194- permissions (:class:`Sequence [str]`):
1204+ permissions (:class:`MutableSequence [str]`):
11951205 The set of permissions to check for the ``resource``.
11961206 Permissions with wildcards (such as '*' or 'storage.*')
11971207 are not allowed. For more information see `IAM
0 commit comments