feat: add context manager support in client

google/cloud/dialogflowcx_v3/services/agents/async_client.py

@@ -881,6 +881,12 @@ async def get_agent_validation_result(
         # 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(

google/cloud/dialogflowcx_v3/services/agents/client.py

@@ -436,10 +436,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_agents(
@@ -1151,6 +1148,19 @@ def get_agent_validation_result(
         # 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(

google/cloud/dialogflowcx_v3/services/agents/transports/base.py

@@ -192,6 +192,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."""

google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py

@@ -515,5 +515,8 @@ def get_agent_validation_result(
             )
         return self._stubs["get_agent_validation_result"]
 
+    def close(self):
+        self.grpc_channel.close()
+
 
 __all__ = ("AgentsGrpcTransport",)

google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py

@@ -524,5 +524,8 @@ def get_agent_validation_result(
             )
         return self._stubs["get_agent_validation_result"]
 
+    def close(self):
+        return self.grpc_channel.close()
+
 
 __all__ = ("AgentsGrpcAsyncIOTransport",)

google/cloud/dialogflowcx_v3/services/deployments/async_client.py

@@ -330,6 +330,12 @@ async def get_deployment(
         # 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(

google/cloud/dialogflowcx_v3/services/deployments/client.py

@@ -413,10 +413,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_deployments(
@@ -581,6 +578,19 @@ def get_deployment(
         # 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(

google/cloud/dialogflowcx_v3/services/deployments/transports/base.py

@@ -165,6 +165,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_deployments(
         self,

google/cloud/dialogflowcx_v3/services/deployments/transports/grpc.py

@@ -282,5 +282,8 @@ def get_deployment(
             )
         return self._stubs["get_deployment"]
 
+    def close(self):
+        self.grpc_channel.close()
+
 
 __all__ = ("DeploymentsGrpcTransport",)

google/cloud/dialogflowcx_v3/services/deployments/transports/grpc_asyncio.py

@@ -286,5 +286,8 @@ def get_deployment(
             )
         return self._stubs["get_deployment"]
 
+    def close(self):
+        return self.grpc_channel.close()
+
 
 __all__ = ("DeploymentsGrpcAsyncIOTransport",)

google/cloud/dialogflowcx_v3/services/entity_types/async_client.py

@@ -646,6 +646,12 @@ async def delete_entity_type(
             request, retry=retry, timeout=timeout, metadata=metadata,
         )
 
+    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(

google/cloud/dialogflowcx_v3/services/entity_types/client.py

@@ -348,10 +348,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_entity_types(
@@ -839,6 +836,19 @@ def delete_entity_type(
             request, retry=retry, timeout=timeout, metadata=metadata,
         )
 
+    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(

google/cloud/dialogflowcx_v3/services/entity_types/transports/base.py

@@ -176,6 +176,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_entity_types(
         self,

google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py

@@ -377,5 +377,8 @@ def delete_entity_type(
             )
         return self._stubs["delete_entity_type"]
 
+    def close(self):
+        self.grpc_channel.close()
+
 
 __all__ = ("EntityTypesGrpcTransport",)

google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py

@@ -385,5 +385,8 @@ def delete_entity_type(
             )
         return self._stubs["delete_entity_type"]
 
+    def close(self):
+        return self.grpc_channel.close()
+
 
 __all__ = ("EntityTypesGrpcAsyncIOTransport",)

google/cloud/dialogflowcx_v3/services/environments/async_client.py

@@ -952,6 +952,12 @@ async def deploy_flow(
         # 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(

google/cloud/dialogflowcx_v3/services/environments/client.py

@@ -434,10 +434,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_environments(
@@ -1219,6 +1216,19 @@ def deploy_flow(
         # 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(

google/cloud/dialogflowcx_v3/services/environments/transports/base.py

@@ -194,6 +194,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."""

google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py

@@ -541,5 +541,8 @@ def deploy_flow(
             )
         return self._stubs["deploy_flow"]
 
+    def close(self):
+        self.grpc_channel.close()
+
 
 __all__ = ("EnvironmentsGrpcTransport",)

google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py

@@ -551,5 +551,8 @@ def deploy_flow(
             )
         return self._stubs["deploy_flow"]
 
+    def close(self):
+        return self.grpc_channel.close()
+
 
 __all__ = ("EnvironmentsGrpcAsyncIOTransport",)

google/cloud/dialogflowcx_v3/services/experiments/async_client.py

@@ -705,6 +705,12 @@ async def stop_experiment(
         # 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(

google/cloud/dialogflowcx_v3/services/experiments/client.py

@@ -372,10 +372,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_experiments(
@@ -918,6 +915,19 @@ def stop_experiment(
         # 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(

google/cloud/dialogflowcx_v3/services/experiments/transports/base.py

@@ -182,6 +182,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_experiments(
         self,

google/cloud/dialogflowcx_v3/services/experiments/transports/grpc.py

@@ -427,5 +427,8 @@ def stop_experiment(
             )
         return self._stubs["stop_experiment"]
 
+    def close(self):
+        self.grpc_channel.close()
+
 
 __all__ = ("ExperimentsGrpcTransport",)

google/cloud/dialogflowcx_v3/services/experiments/transports/grpc_asyncio.py

@@ -433,5 +433,8 @@ def stop_experiment(
             )
         return self._stubs["stop_experiment"]
 
+    def close(self):
+        return self.grpc_channel.close()
+
 
 __all__ = ("ExperimentsGrpcAsyncIOTransport",)