diff --git a/google/cloud/resourcemanager_v3/services/folders/async_client.py b/google/cloud/resourcemanager_v3/services/folders/async_client.py index e847d11..93ed8c6 100644 --- a/google/cloud/resourcemanager_v3/services/folders/async_client.py +++ b/google/cloud/resourcemanager_v3/services/folders/async_client.py @@ -1319,6 +1319,12 @@ async def test_iam_permissions( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/folders/client.py b/google/cloud/resourcemanager_v3/services/folders/client.py index d3c0756..6b087ab 100644 --- a/google/cloud/resourcemanager_v3/services/folders/client.py +++ b/google/cloud/resourcemanager_v3/services/folders/client.py @@ -347,10 +347,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def get_folder( @@ -1479,6 +1476,19 @@ def test_iam_permissions( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/folders/transports/base.py b/google/cloud/resourcemanager_v3/services/folders/transports/base.py index 4bc5e57..1346f95 100644 --- a/google/cloud/resourcemanager_v3/services/folders/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/folders/transports/base.py @@ -231,6 +231,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def operations_client(self) -> operations_v1.OperationsClient: """Return the client designed to process long-running operations.""" diff --git a/google/cloud/resourcemanager_v3/services/folders/transports/grpc.py b/google/cloud/resourcemanager_v3/services/folders/transports/grpc.py index e746220..9823b51 100644 --- a/google/cloud/resourcemanager_v3/services/folders/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/folders/transports/grpc.py @@ -648,5 +648,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + self.grpc_channel.close() + __all__ = ("FoldersGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/folders/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/folders/transports/grpc_asyncio.py index 4100de3..0319870 100644 --- a/google/cloud/resourcemanager_v3/services/folders/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/folders/transports/grpc_asyncio.py @@ -657,5 +657,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + return self.grpc_channel.close() + __all__ = ("FoldersGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/services/organizations/async_client.py b/google/cloud/resourcemanager_v3/services/organizations/async_client.py index c64e4b0..36154d7 100644 --- a/google/cloud/resourcemanager_v3/services/organizations/async_client.py +++ b/google/cloud/resourcemanager_v3/services/organizations/async_client.py @@ -711,6 +711,12 @@ async def test_iam_permissions( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/organizations/client.py b/google/cloud/resourcemanager_v3/services/organizations/client.py index 3292311..90da938 100644 --- a/google/cloud/resourcemanager_v3/services/organizations/client.py +++ b/google/cloud/resourcemanager_v3/services/organizations/client.py @@ -340,10 +340,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def get_organization( @@ -872,6 +869,19 @@ def test_iam_permissions( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/organizations/transports/base.py b/google/cloud/resourcemanager_v3/services/organizations/transports/base.py index 3292793..fc606e3 100644 --- a/google/cloud/resourcemanager_v3/services/organizations/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/organizations/transports/base.py @@ -202,6 +202,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def get_organization( self, diff --git a/google/cloud/resourcemanager_v3/services/organizations/transports/grpc.py b/google/cloud/resourcemanager_v3/services/organizations/transports/grpc.py index 8ec5128..013ff83 100644 --- a/google/cloud/resourcemanager_v3/services/organizations/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/organizations/transports/grpc.py @@ -389,5 +389,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + self.grpc_channel.close() + __all__ = ("OrganizationsGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/organizations/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/organizations/transports/grpc_asyncio.py index f6141e6..063f470 100644 --- a/google/cloud/resourcemanager_v3/services/organizations/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/organizations/transports/grpc_asyncio.py @@ -394,5 +394,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + return self.grpc_channel.close() + __all__ = ("OrganizationsGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/services/projects/async_client.py b/google/cloud/resourcemanager_v3/services/projects/async_client.py index 00f47fe..6498948 100644 --- a/google/cloud/resourcemanager_v3/services/projects/async_client.py +++ b/google/cloud/resourcemanager_v3/services/projects/async_client.py @@ -1384,6 +1384,12 @@ async def test_iam_permissions( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/projects/client.py b/google/cloud/resourcemanager_v3/services/projects/client.py index a9adef6..5a16078 100644 --- a/google/cloud/resourcemanager_v3/services/projects/client.py +++ b/google/cloud/resourcemanager_v3/services/projects/client.py @@ -343,10 +343,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def get_project( @@ -1544,6 +1541,19 @@ def test_iam_permissions( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/projects/transports/base.py b/google/cloud/resourcemanager_v3/services/projects/transports/base.py index c70201c..4bf8cc2 100644 --- a/google/cloud/resourcemanager_v3/services/projects/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/projects/transports/base.py @@ -231,6 +231,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def operations_client(self) -> operations_v1.OperationsClient: """Return the client designed to process long-running operations.""" diff --git a/google/cloud/resourcemanager_v3/services/projects/transports/grpc.py b/google/cloud/resourcemanager_v3/services/projects/transports/grpc.py index a94f745..34820c2 100644 --- a/google/cloud/resourcemanager_v3/services/projects/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/projects/transports/grpc.py @@ -670,5 +670,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + self.grpc_channel.close() + __all__ = ("ProjectsGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/projects/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/projects/transports/grpc_asyncio.py index 79f0b14..e5372c9 100644 --- a/google/cloud/resourcemanager_v3/services/projects/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/projects/transports/grpc_asyncio.py @@ -683,5 +683,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + return self.grpc_channel.close() + __all__ = ("ProjectsGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_bindings/async_client.py b/google/cloud/resourcemanager_v3/services/tag_bindings/async_client.py index f9d187e..18e663a 100644 --- a/google/cloud/resourcemanager_v3/services/tag_bindings/async_client.py +++ b/google/cloud/resourcemanager_v3/services/tag_bindings/async_client.py @@ -424,6 +424,12 @@ async def delete_tag_binding( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_bindings/client.py b/google/cloud/resourcemanager_v3/services/tag_bindings/client.py index e763b64..ab35fd1 100644 --- a/google/cloud/resourcemanager_v3/services/tag_bindings/client.py +++ b/google/cloud/resourcemanager_v3/services/tag_bindings/client.py @@ -343,10 +343,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def list_tag_bindings( @@ -601,6 +598,19 @@ def delete_tag_binding( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/base.py b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/base.py index 2cead6e..5adc37b 100644 --- a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/base.py @@ -181,6 +181,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def operations_client(self) -> operations_v1.OperationsClient: """Return the client designed to process long-running operations.""" diff --git a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc.py b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc.py index de225a5..d42e9c9 100644 --- a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc.py @@ -330,5 +330,8 @@ def delete_tag_binding( ) return self._stubs["delete_tag_binding"] + def close(self): + self.grpc_channel.close() + __all__ = ("TagBindingsGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc_asyncio.py index d33d054..79d2ea3 100644 --- a/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/tag_bindings/transports/grpc_asyncio.py @@ -340,5 +340,8 @@ def delete_tag_binding( ) return self._stubs["delete_tag_binding"] + def close(self): + return self.grpc_channel.close() + __all__ = ("TagBindingsGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_keys/async_client.py b/google/cloud/resourcemanager_v3/services/tag_keys/async_client.py index 0c5c81f..8f9584f 100644 --- a/google/cloud/resourcemanager_v3/services/tag_keys/async_client.py +++ b/google/cloud/resourcemanager_v3/services/tag_keys/async_client.py @@ -946,6 +946,12 @@ async def test_iam_permissions( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_keys/client.py b/google/cloud/resourcemanager_v3/services/tag_keys/client.py index ca52b35..4c6bad6 100644 --- a/google/cloud/resourcemanager_v3/services/tag_keys/client.py +++ b/google/cloud/resourcemanager_v3/services/tag_keys/client.py @@ -343,10 +343,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def list_tag_keys( @@ -1106,6 +1103,19 @@ def test_iam_permissions( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_keys/transports/base.py b/google/cloud/resourcemanager_v3/services/tag_keys/transports/base.py index be4d62b..8ec82af 100644 --- a/google/cloud/resourcemanager_v3/services/tag_keys/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/tag_keys/transports/base.py @@ -222,6 +222,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def operations_client(self) -> operations_v1.OperationsClient: """Return the client designed to process long-running operations.""" diff --git a/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc.py b/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc.py index 94ea9f7..b7aeb6b 100644 --- a/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc.py @@ -473,5 +473,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + self.grpc_channel.close() + __all__ = ("TagKeysGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc_asyncio.py index 05f4e3a..56146d4 100644 --- a/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/tag_keys/transports/grpc_asyncio.py @@ -482,5 +482,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + return self.grpc_channel.close() + __all__ = ("TagKeysGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_values/async_client.py b/google/cloud/resourcemanager_v3/services/tag_values/async_client.py index 3bcbe55..7214a39 100644 --- a/google/cloud/resourcemanager_v3/services/tag_values/async_client.py +++ b/google/cloud/resourcemanager_v3/services/tag_values/async_client.py @@ -946,6 +946,12 @@ async def test_iam_permissions( # Done; return the response. return response + async def __aenter__(self): + return self + + async def __aexit__(self, exc_type, exc, tb): + await self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_values/client.py b/google/cloud/resourcemanager_v3/services/tag_values/client.py index 3c022ae..657041c 100644 --- a/google/cloud/resourcemanager_v3/services/tag_values/client.py +++ b/google/cloud/resourcemanager_v3/services/tag_values/client.py @@ -343,10 +343,7 @@ def __init__( client_cert_source_for_mtls=client_cert_source_func, quota_project_id=client_options.quota_project_id, client_info=client_info, - always_use_jwt_access=( - Transport == type(self).get_transport_class("grpc") - or Transport == type(self).get_transport_class("grpc_asyncio") - ), + always_use_jwt_access=True, ) def list_tag_values( @@ -1104,6 +1101,19 @@ def test_iam_permissions( # Done; return the response. return response + def __enter__(self): + return self + + def __exit__(self, type, value, traceback): + """Releases underlying transport's resources. + + .. warning:: + ONLY use as a context manager if the transport is NOT shared + with other clients! Exiting the with block will CLOSE the transport + and may cause errors in other clients! + """ + self.transport.close() + try: DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo( diff --git a/google/cloud/resourcemanager_v3/services/tag_values/transports/base.py b/google/cloud/resourcemanager_v3/services/tag_values/transports/base.py index e42a4a2..325cb3f 100644 --- a/google/cloud/resourcemanager_v3/services/tag_values/transports/base.py +++ b/google/cloud/resourcemanager_v3/services/tag_values/transports/base.py @@ -222,6 +222,15 @@ def _prep_wrapped_messages(self, client_info): ), } + def close(self): + """Closes resources associated with the transport. + + .. warning:: + Only call this method if the transport is NOT shared + with other clients - this may cause errors in other clients! + """ + raise NotImplementedError() + @property def operations_client(self) -> operations_v1.OperationsClient: """Return the client designed to process long-running operations.""" diff --git a/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc.py b/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc.py index db33fca..22ca797 100644 --- a/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc.py +++ b/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc.py @@ -476,5 +476,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + self.grpc_channel.close() + __all__ = ("TagValuesGrpcTransport",) diff --git a/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc_asyncio.py b/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc_asyncio.py index 6b60acb..1f07062 100644 --- a/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc_asyncio.py +++ b/google/cloud/resourcemanager_v3/services/tag_values/transports/grpc_asyncio.py @@ -489,5 +489,8 @@ def test_iam_permissions( ) return self._stubs["test_iam_permissions"] + def close(self): + return self.grpc_channel.close() + __all__ = ("TagValuesGrpcAsyncIOTransport",) diff --git a/google/cloud/resourcemanager_v3/types/folders.py b/google/cloud/resourcemanager_v3/types/folders.py index 79a43c8..6f02669 100644 --- a/google/cloud/resourcemanager_v3/types/folders.py +++ b/google/cloud/resourcemanager_v3/types/folders.py @@ -297,7 +297,8 @@ class UpdateFolderRequest(proto.Message): class UpdateFolderMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by UpdateFolder. - """ + + """ class MoveFolderRequest(proto.Message): @@ -350,7 +351,8 @@ class DeleteFolderRequest(proto.Message): class DeleteFolderMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the ``Operation`` returned by ``DeleteFolder``. - """ + + """ class UndeleteFolderRequest(proto.Message): @@ -368,7 +370,8 @@ class UndeleteFolderRequest(proto.Message): class UndeleteFolderMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the ``Operation`` returned by ``UndeleteFolder``. - """ + + """ __all__ = tuple(sorted(__protobuf__.manifest)) diff --git a/google/cloud/resourcemanager_v3/types/organizations.py b/google/cloud/resourcemanager_v3/types/organizations.py index 008eb1d..402244f 100644 --- a/google/cloud/resourcemanager_v3/types/organizations.py +++ b/google/cloud/resourcemanager_v3/types/organizations.py @@ -105,6 +105,7 @@ class GetOrganizationRequest(proto.Message): class SearchOrganizationsRequest(proto.Message): r"""The request sent to the ``SearchOrganizations`` method. + Attributes: page_size (int): Optional. The maximum number of organizations @@ -143,6 +144,7 @@ class SearchOrganizationsRequest(proto.Message): class SearchOrganizationsResponse(proto.Message): r"""The response returned from the ``SearchOrganizations`` method. + Attributes: organizations (Sequence[google.cloud.resourcemanager_v3.types.Organization]): The list of Organizations that matched the @@ -171,13 +173,15 @@ def raw_page(self): class DeleteOrganizationMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the operation returned by DeleteOrganization. - """ + + """ class UndeleteOrganizationMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by UndeleteOrganization. - """ + + """ __all__ = tuple(sorted(__protobuf__.manifest)) diff --git a/google/cloud/resourcemanager_v3/types/projects.py b/google/cloud/resourcemanager_v3/types/projects.py index 8a1c934..75edde6 100644 --- a/google/cloud/resourcemanager_v3/types/projects.py +++ b/google/cloud/resourcemanager_v3/types/projects.py @@ -385,7 +385,8 @@ class UpdateProjectRequest(proto.Message): class UpdateProjectMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by UpdateProject. - """ + + """ class MoveProjectRequest(proto.Message): @@ -408,7 +409,8 @@ class MoveProjectRequest(proto.Message): class MoveProjectMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by MoveProject. - """ + + """ class DeleteProjectRequest(proto.Message): @@ -427,7 +429,8 @@ class DeleteProjectRequest(proto.Message): class DeleteProjectMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by ``DeleteProject``. - """ + + """ class UndeleteProjectRequest(proto.Message): @@ -448,7 +451,8 @@ class UndeleteProjectRequest(proto.Message): class UndeleteProjectMetadata(proto.Message): r"""A status object which is used as the ``metadata`` field for the Operation returned by ``UndeleteProject``. - """ + + """ __all__ = tuple(sorted(__protobuf__.manifest)) diff --git a/google/cloud/resourcemanager_v3/types/tag_bindings.py b/google/cloud/resourcemanager_v3/types/tag_bindings.py index 5ba5a20..d718282 100644 --- a/google/cloud/resourcemanager_v3/types/tag_bindings.py +++ b/google/cloud/resourcemanager_v3/types/tag_bindings.py @@ -57,11 +57,13 @@ class TagBinding(proto.Message): class CreateTagBindingMetadata(proto.Message): - r"""Runtime operation information for creating a TagValue. """ + r"""Runtime operation information for creating a TagValue. + """ class CreateTagBindingRequest(proto.Message): r"""The request message to create a TagBinding. + Attributes: tag_binding (google.cloud.resourcemanager_v3.types.TagBinding): Required. The TagBinding to be created. @@ -76,11 +78,13 @@ class CreateTagBindingRequest(proto.Message): class DeleteTagBindingMetadata(proto.Message): - r"""Runtime operation information for deleting a TagBinding. """ + r"""Runtime operation information for deleting a TagBinding. + """ class DeleteTagBindingRequest(proto.Message): r"""The request message to delete a TagBinding. + Attributes: name (str): Required. The name of the TagBinding. This is a String of @@ -93,6 +97,7 @@ class DeleteTagBindingRequest(proto.Message): class ListTagBindingsRequest(proto.Message): r"""The request message to list all TagBindings for a parent. + Attributes: parent (str): Required. The full resource name of a @@ -118,6 +123,7 @@ class ListTagBindingsRequest(proto.Message): class ListTagBindingsResponse(proto.Message): r"""The ListTagBindings response. + Attributes: tag_bindings (Sequence[google.cloud.resourcemanager_v3.types.TagBinding]): A possibly paginated list of TagBindings for diff --git a/google/cloud/resourcemanager_v3/types/tag_keys.py b/google/cloud/resourcemanager_v3/types/tag_keys.py index 6f34e7b..251a6d8 100644 --- a/google/cloud/resourcemanager_v3/types/tag_keys.py +++ b/google/cloud/resourcemanager_v3/types/tag_keys.py @@ -38,6 +38,7 @@ class TagKey(proto.Message): r"""A TagKey, used to group a set of TagValues. + Attributes: name (str): Immutable. The resource name for a TagKey. Must be in the @@ -110,6 +111,7 @@ class ListTagKeysRequest(proto.Message): class ListTagKeysResponse(proto.Message): r"""The ListTagKeys response message. + Attributes: tag_keys (Sequence[google.cloud.resourcemanager_v3.types.TagKey]): List of TagKeys that live under the specified @@ -130,6 +132,7 @@ def raw_page(self): class GetTagKeyRequest(proto.Message): r"""The request message for getting a TagKey. + Attributes: name (str): Required. A resource name in the format ``tagKeys/{id}``, @@ -141,6 +144,7 @@ class GetTagKeyRequest(proto.Message): class CreateTagKeyRequest(proto.Message): r"""The request message for creating a TagKey. + Attributes: tag_key (google.cloud.resourcemanager_v3.types.TagKey): Required. The TagKey to be created. Only fields @@ -157,11 +161,13 @@ class CreateTagKeyRequest(proto.Message): class CreateTagKeyMetadata(proto.Message): - r"""Runtime operation information for creating a TagKey. """ + r"""Runtime operation information for creating a TagKey. + """ class UpdateTagKeyRequest(proto.Message): r"""The request message for updating a TagKey. + Attributes: tag_key (google.cloud.resourcemanager_v3.types.TagKey): Required. The new definition of the TagKey. Only the @@ -187,11 +193,13 @@ class UpdateTagKeyRequest(proto.Message): class UpdateTagKeyMetadata(proto.Message): - r"""Runtime operation information for updating a TagKey. """ + r"""Runtime operation information for updating a TagKey. + """ class DeleteTagKeyRequest(proto.Message): r"""The request message for deleting a TagKey. + Attributes: name (str): Required. The resource name of a TagKey to be deleted in the @@ -213,7 +221,8 @@ class DeleteTagKeyRequest(proto.Message): class DeleteTagKeyMetadata(proto.Message): - r"""Runtime operation information for deleting a TagKey. """ + r"""Runtime operation information for deleting a TagKey. + """ __all__ = tuple(sorted(__protobuf__.manifest)) diff --git a/google/cloud/resourcemanager_v3/types/tag_values.py b/google/cloud/resourcemanager_v3/types/tag_values.py index 9618ea6..9899cfd 100644 --- a/google/cloud/resourcemanager_v3/types/tag_values.py +++ b/google/cloud/resourcemanager_v3/types/tag_values.py @@ -114,6 +114,7 @@ class ListTagValuesRequest(proto.Message): class ListTagValuesResponse(proto.Message): r"""The ListTagValues response. + Attributes: tag_values (Sequence[google.cloud.resourcemanager_v3.types.TagValue]): A possibly paginated list of TagValues that @@ -136,6 +137,7 @@ def raw_page(self): class GetTagValueRequest(proto.Message): r"""The request message for getting a TagValue. + Attributes: name (str): Required. Resource name for TagValue to be fetched in the @@ -147,6 +149,7 @@ class GetTagValueRequest(proto.Message): class CreateTagValueRequest(proto.Message): r"""The request message for creating a TagValue. + Attributes: tag_value (google.cloud.resourcemanager_v3.types.TagValue): Required. The TagValue to be created. Only fields @@ -163,11 +166,13 @@ class CreateTagValueRequest(proto.Message): class CreateTagValueMetadata(proto.Message): - r"""Runtime operation information for creating a TagValue. """ + r"""Runtime operation information for creating a TagValue. + """ class UpdateTagValueRequest(proto.Message): r"""The request message for updating a TagValue. + Attributes: tag_value (google.cloud.resourcemanager_v3.types.TagValue): Required. The new definition of the TagValue. Only fields @@ -191,11 +196,13 @@ class UpdateTagValueRequest(proto.Message): class UpdateTagValueMetadata(proto.Message): - r"""Runtime operation information for updating a TagValue. """ + r"""Runtime operation information for updating a TagValue. + """ class DeleteTagValueRequest(proto.Message): r"""The request message for deleting a TagValue. + Attributes: name (str): Required. Resource name for TagValue to be @@ -216,7 +223,8 @@ class DeleteTagValueRequest(proto.Message): class DeleteTagValueMetadata(proto.Message): - r"""Runtime operation information for deleting a TagValue. """ + r"""Runtime operation information for deleting a TagValue. + """ __all__ = tuple(sorted(__protobuf__.manifest)) diff --git a/tests/unit/gapic/resourcemanager_v3/test_folders.py b/tests/unit/gapic/resourcemanager_v3/test_folders.py index 2004016..281d050 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_folders.py +++ b/tests/unit/gapic/resourcemanager_v3/test_folders.py @@ -32,6 +32,7 @@ from google.api_core import grpc_helpers_async from google.api_core import operation_async # type: ignore from google.api_core import operations_v1 +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.folders import FoldersAsyncClient @@ -2909,6 +2910,9 @@ def test_folders_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + # Additionally, the LRO client (a property) should # also raise NotImplementedError with pytest.raises(NotImplementedError): @@ -3420,3 +3424,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = FoldersAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = FoldersClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = FoldersClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called() diff --git a/tests/unit/gapic/resourcemanager_v3/test_organizations.py b/tests/unit/gapic/resourcemanager_v3/test_organizations.py index df7d9de..4f44b45 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_organizations.py +++ b/tests/unit/gapic/resourcemanager_v3/test_organizations.py @@ -29,6 +29,7 @@ from google.api_core import gapic_v1 from google.api_core import grpc_helpers from google.api_core import grpc_helpers_async +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.organizations import ( @@ -1832,6 +1833,9 @@ def test_organizations_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + @requires_google_auth_gte_1_25_0 def test_organizations_base_transport_with_credentials_file(): @@ -2327,3 +2331,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = OrganizationsAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = OrganizationsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = OrganizationsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called() diff --git a/tests/unit/gapic/resourcemanager_v3/test_projects.py b/tests/unit/gapic/resourcemanager_v3/test_projects.py index 61b1243..83ce464 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_projects.py +++ b/tests/unit/gapic/resourcemanager_v3/test_projects.py @@ -32,6 +32,7 @@ from google.api_core import grpc_helpers_async from google.api_core import operation_async # type: ignore from google.api_core import operations_v1 +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.projects import ProjectsAsyncClient @@ -2940,6 +2941,9 @@ def test_projects_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + # Additionally, the LRO client (a property) should # also raise NotImplementedError with pytest.raises(NotImplementedError): @@ -3451,3 +3455,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = ProjectsAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = ProjectsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = ProjectsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called() diff --git a/tests/unit/gapic/resourcemanager_v3/test_tag_bindings.py b/tests/unit/gapic/resourcemanager_v3/test_tag_bindings.py index 181d9d9..9df042d 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_tag_bindings.py +++ b/tests/unit/gapic/resourcemanager_v3/test_tag_bindings.py @@ -32,6 +32,7 @@ from google.api_core import grpc_helpers_async from google.api_core import operation_async # type: ignore from google.api_core import operations_v1 +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.tag_bindings import TagBindingsAsyncClient @@ -1264,6 +1265,9 @@ def test_tag_bindings_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + # Additionally, the LRO client (a property) should # also raise NotImplementedError with pytest.raises(NotImplementedError): @@ -1775,3 +1779,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = TagBindingsAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = TagBindingsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = TagBindingsClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called() diff --git a/tests/unit/gapic/resourcemanager_v3/test_tag_keys.py b/tests/unit/gapic/resourcemanager_v3/test_tag_keys.py index 1d802c9..52e9e37 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_tag_keys.py +++ b/tests/unit/gapic/resourcemanager_v3/test_tag_keys.py @@ -32,6 +32,7 @@ from google.api_core import grpc_helpers_async from google.api_core import operation_async # type: ignore from google.api_core import operations_v1 +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.tag_keys import TagKeysAsyncClient @@ -2266,6 +2267,9 @@ def test_tag_keys_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + # Additionally, the LRO client (a property) should # also raise NotImplementedError with pytest.raises(NotImplementedError): @@ -2777,3 +2781,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = TagKeysAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = TagKeysClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = TagKeysClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called() diff --git a/tests/unit/gapic/resourcemanager_v3/test_tag_values.py b/tests/unit/gapic/resourcemanager_v3/test_tag_values.py index 4e829de..29f2486 100644 --- a/tests/unit/gapic/resourcemanager_v3/test_tag_values.py +++ b/tests/unit/gapic/resourcemanager_v3/test_tag_values.py @@ -32,6 +32,7 @@ from google.api_core import grpc_helpers_async from google.api_core import operation_async # type: ignore from google.api_core import operations_v1 +from google.api_core import path_template from google.auth import credentials as ga_credentials from google.auth.exceptions import MutualTLSChannelError from google.cloud.resourcemanager_v3.services.tag_values import TagValuesAsyncClient @@ -2305,6 +2306,9 @@ def test_tag_values_base_transport(): with pytest.raises(NotImplementedError): getattr(transport, method)(request=object()) + with pytest.raises(NotImplementedError): + transport.close() + # Additionally, the LRO client (a property) should # also raise NotImplementedError with pytest.raises(NotImplementedError): @@ -2816,3 +2820,49 @@ def test_client_withDEFAULT_CLIENT_INFO(): credentials=ga_credentials.AnonymousCredentials(), client_info=client_info, ) prep.assert_called_once_with(client_info) + + +@pytest.mark.asyncio +async def test_transport_close_async(): + client = TagValuesAsyncClient( + credentials=ga_credentials.AnonymousCredentials(), transport="grpc_asyncio", + ) + with mock.patch.object( + type(getattr(client.transport, "grpc_channel")), "close" + ) as close: + async with client: + close.assert_not_called() + close.assert_called_once() + + +def test_transport_close(): + transports = { + "grpc": "_grpc_channel", + } + + for transport, close_name in transports.items(): + client = TagValuesClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + with mock.patch.object( + type(getattr(client.transport, close_name)), "close" + ) as close: + with client: + close.assert_not_called() + close.assert_called_once() + + +def test_client_ctx(): + transports = [ + "grpc", + ] + for transport in transports: + client = TagValuesClient( + credentials=ga_credentials.AnonymousCredentials(), transport=transport + ) + # Test client calls underlying transport. + with mock.patch.object(type(client.transport), "close") as close: + close.assert_not_called() + with client: + pass + close.assert_called()