Skip to content

Commit

Permalink
feat: add context manager support in client (#157)
Browse files Browse the repository at this point in the history
- [ ] Regenerate this pull request now.

chore: fix docstring for first attribute of protos

committer: @busunkim96
PiperOrigin-RevId: 401271153

Source-Link: googleapis/googleapis@787f8c9

Source-Link: googleapis/googleapis-gen@81decff
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiODFkZWNmZmU5ZmM3MjM5NmE4MTUzZTc1NmQxZDY3YTZlZWNmZDYyMCJ9
  • Loading branch information
gcf-owl-bot[bot] committed Oct 8, 2021
1 parent f774c8b commit d02e2bd
Show file tree
Hide file tree
Showing 14 changed files with 285 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3491,6 +3491,12 @@ async def list_usable_subnetworks(
# 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(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -329,10 +329,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_clusters(
Expand Down Expand Up @@ -3588,6 +3585,19 @@ def list_usable_subnetworks(
# 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(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -373,6 +373,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 list_clusters(
self,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1123,5 +1123,8 @@ def list_usable_subnetworks(
)
return self._stubs["list_usable_subnetworks"]

def close(self):
self.grpc_channel.close()


__all__ = ("ClusterManagerGrpcTransport",)
Original file line number Diff line number Diff line change
Expand Up @@ -1173,5 +1173,8 @@ def list_usable_subnetworks(
)
return self._stubs["list_usable_subnetworks"]

def close(self):
return self.grpc_channel.close()


__all__ = ("ClusterManagerGrpcAsyncIOTransport",)
Loading

0 comments on commit d02e2bd

Please sign in to comment.