From 09919b0e45517cedcbb1d8b5b931c7317be549b2 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Mon, 28 Dec 2020 10:19:04 -0800 Subject: [PATCH] feat: allowed custom to specify webhook headers through query parameters (#32) feat: allowed custom to specify webhook headers through query parameters (#32) fix: remove gRPC send/recv limit; add enums to `types/__init__.py` --- .pre-commit-config.yaml | 2 +- google/cloud/dialogflowcx_v3/__init__.py | 2 +- .../services/agents/transports/__init__.py | 1 - .../services/agents/transports/grpc.py | 19 +- .../agents/transports/grpc_asyncio.py | 15 +- .../entity_types/transports/__init__.py | 1 - .../services/entity_types/transports/grpc.py | 10 +- .../entity_types/transports/grpc_asyncio.py | 8 + .../environments/transports/__init__.py | 1 - .../services/environments/transports/grpc.py | 19 +- .../environments/transports/grpc_asyncio.py | 15 +- .../services/flows/transports/__init__.py | 1 - .../services/flows/transports/grpc.py | 19 +- .../services/flows/transports/grpc_asyncio.py | 15 +- .../services/intents/transports/__init__.py | 1 - .../services/intents/transports/grpc.py | 10 +- .../intents/transports/grpc_asyncio.py | 8 + .../services/pages/transports/__init__.py | 1 - .../services/pages/transports/grpc.py | 10 +- .../services/pages/transports/grpc_asyncio.py | 8 + .../transports/__init__.py | 1 - .../transports/grpc.py | 10 +- .../transports/grpc_asyncio.py | 8 + .../transports/__init__.py | 1 - .../session_entity_types/transports/grpc.py | 10 +- .../transports/grpc_asyncio.py | 8 + .../services/sessions/transports/__init__.py | 1 - .../services/sessions/transports/grpc.py | 10 +- .../sessions/transports/grpc_asyncio.py | 8 + .../transports/__init__.py | 1 - .../transports/grpc.py | 10 +- .../transports/grpc_asyncio.py | 8 + .../services/versions/transports/__init__.py | 1 - .../services/versions/transports/grpc.py | 19 +- .../versions/transports/grpc_asyncio.py | 15 +- .../services/webhooks/transports/__init__.py | 1 - .../services/webhooks/transports/grpc.py | 10 +- .../webhooks/transports/grpc_asyncio.py | 8 + .../cloud/dialogflowcx_v3/types/__init__.py | 11 +- google/cloud/dialogflowcx_v3beta1/__init__.py | 2 +- .../services/agents/transports/__init__.py | 1 - .../services/agents/transports/grpc.py | 19 +- .../agents/transports/grpc_asyncio.py | 15 +- .../entity_types/transports/__init__.py | 1 - .../services/entity_types/transports/grpc.py | 10 +- .../entity_types/transports/grpc_asyncio.py | 8 + .../environments/transports/__init__.py | 1 - .../services/environments/transports/grpc.py | 19 +- .../environments/transports/grpc_asyncio.py | 15 +- .../services/flows/transports/__init__.py | 1 - .../services/flows/transports/grpc.py | 19 +- .../services/flows/transports/grpc_asyncio.py | 15 +- .../services/intents/transports/__init__.py | 1 - .../services/intents/transports/grpc.py | 10 +- .../intents/transports/grpc_asyncio.py | 8 + .../services/pages/transports/__init__.py | 1 - .../services/pages/transports/grpc.py | 10 +- .../services/pages/transports/grpc_asyncio.py | 8 + .../transports/__init__.py | 1 - .../session_entity_types/transports/grpc.py | 10 +- .../transports/grpc_asyncio.py | 8 + .../services/sessions/async_client.py | 25 +- .../services/sessions/client.py | 25 +- .../services/sessions/transports/__init__.py | 1 - .../services/sessions/transports/grpc.py | 35 +- .../sessions/transports/grpc_asyncio.py | 33 +- .../transports/__init__.py | 1 - .../transports/grpc.py | 10 +- .../transports/grpc_asyncio.py | 8 + .../services/versions/transports/__init__.py | 1 - .../services/versions/transports/grpc.py | 19 +- .../versions/transports/grpc_asyncio.py | 15 +- .../services/webhooks/transports/__init__.py | 1 - .../services/webhooks/transports/grpc.py | 10 +- .../webhooks/transports/grpc_asyncio.py | 8 + .../dialogflowcx_v3beta1/types/__init__.py | 11 +- .../types/response_message.py | 52 +-- .../dialogflowcx_v3beta1/types/session.py | 23 ++ synth.metadata | 333 +++++++++++++++++- .../unit/gapic/dialogflowcx_v3/test_agents.py | 8 + .../dialogflowcx_v3/test_entity_types.py | 8 + .../dialogflowcx_v3/test_environments.py | 8 + .../unit/gapic/dialogflowcx_v3/test_flows.py | 8 + .../gapic/dialogflowcx_v3/test_intents.py | 8 + .../unit/gapic/dialogflowcx_v3/test_pages.py | 8 + .../test_security_settings_service.py | 8 + .../test_session_entity_types.py | 8 + .../gapic/dialogflowcx_v3/test_sessions.py | 8 + .../test_transition_route_groups.py | 8 + .../gapic/dialogflowcx_v3/test_versions.py | 8 + .../gapic/dialogflowcx_v3/test_webhooks.py | 8 + .../gapic/dialogflowcx_v3beta1/test_agents.py | 8 + .../dialogflowcx_v3beta1/test_entity_types.py | 8 + .../dialogflowcx_v3beta1/test_environments.py | 8 + .../gapic/dialogflowcx_v3beta1/test_flows.py | 8 + .../dialogflowcx_v3beta1/test_intents.py | 8 + .../gapic/dialogflowcx_v3beta1/test_pages.py | 8 + .../test_session_entity_types.py | 8 + .../dialogflowcx_v3beta1/test_sessions.py | 8 + .../test_transition_route_groups.py | 8 + .../dialogflowcx_v3beta1/test_versions.py | 8 + .../dialogflowcx_v3beta1/test_webhooks.py | 8 + 102 files changed, 1104 insertions(+), 181 deletions(-) diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 6ad83346..a9024b15 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -2,7 +2,7 @@ # See https://pre-commit.com/hooks.html for more hooks repos: - repo: https://github.com/pre-commit/pre-commit-hooks - rev: v3.3.0 + rev: v3.4.0 hooks: - id: trailing-whitespace - id: end-of-file-fixer diff --git a/google/cloud/dialogflowcx_v3/__init__.py b/google/cloud/dialogflowcx_v3/__init__.py index 791c87bc..e3900313 100644 --- a/google/cloud/dialogflowcx_v3/__init__.py +++ b/google/cloud/dialogflowcx_v3/__init__.py @@ -194,7 +194,6 @@ "ExportAgentRequest", "ExportAgentResponse", "Flow", - "FlowsClient", "Form", "FulfillIntentRequest", "FulfillIntentResponse", @@ -292,4 +291,5 @@ "WebhookRequest", "WebhookResponse", "WebhooksClient", + "FlowsClient", ) diff --git a/google/cloud/dialogflowcx_v3/services/agents/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/agents/transports/__init__.py index a87abc01..dfed9192 100644 --- a/google/cloud/dialogflowcx_v3/services/agents/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/agents/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = AgentsGrpcTransport _transport_registry["grpc_asyncio"] = AgentsGrpcAsyncIOTransport - __all__ = ( "AgentsTransport", "AgentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py index bbf09619..496da86b 100644 --- a/google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py @@ -150,6 +150,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -168,9 +172,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -194,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -241,13 +250,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_agents( diff --git a/google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py index 8c5b8e48..fb4eb8fb 100644 --- a/google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py @@ -195,6 +195,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -213,6 +217,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -226,6 +234,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -245,13 +254,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_agents( diff --git a/google/cloud/dialogflowcx_v3/services/entity_types/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/entity_types/transports/__init__.py index bd6250cb..963959d1 100644 --- a/google/cloud/dialogflowcx_v3/services/entity_types/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/entity_types/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = EntityTypesGrpcTransport _transport_registry["grpc_asyncio"] = EntityTypesGrpcAsyncIOTransport - __all__ = ( "EntityTypesTransport", "EntityTypesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py index 490b6fac..e4f92f71 100644 --- a/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py index 5729cc64..a3c09563 100644 --- a/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/environments/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/environments/transports/__init__.py index 14f04446..aff44bcd 100644 --- a/google/cloud/dialogflowcx_v3/services/environments/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/environments/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = EnvironmentsGrpcTransport _transport_registry["grpc_asyncio"] = EnvironmentsGrpcAsyncIOTransport - __all__ = ( "EnvironmentsTransport", "EnvironmentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py index 3086e047..2ee7c39d 100644 --- a/google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_environments( diff --git a/google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py index e6a2594f..4d0a66ca 100644 --- a/google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_environments( diff --git a/google/cloud/dialogflowcx_v3/services/flows/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/flows/transports/__init__.py index d43aadd7..3789db2a 100644 --- a/google/cloud/dialogflowcx_v3/services/flows/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/flows/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = FlowsGrpcTransport _transport_registry["grpc_asyncio"] = FlowsGrpcAsyncIOTransport - __all__ = ( "FlowsTransport", "FlowsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/flows/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/flows/transports/grpc.py index 6efec1ad..3089c3bc 100644 --- a/google/cloud/dialogflowcx_v3/services/flows/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/flows/transports/grpc.py @@ -150,6 +150,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -168,9 +172,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -194,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -241,13 +250,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def create_flow(self) -> Callable[[gcdc_flow.CreateFlowRequest], gcdc_flow.Flow]: diff --git a/google/cloud/dialogflowcx_v3/services/flows/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/flows/transports/grpc_asyncio.py index 98ff7b16..67607e70 100644 --- a/google/cloud/dialogflowcx_v3/services/flows/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/flows/transports/grpc_asyncio.py @@ -195,6 +195,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -213,6 +217,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -226,6 +234,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -245,13 +254,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def create_flow( diff --git a/google/cloud/dialogflowcx_v3/services/intents/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/intents/transports/__init__.py index ecbfad6b..41fde33b 100644 --- a/google/cloud/dialogflowcx_v3/services/intents/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/intents/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = IntentsGrpcTransport _transport_registry["grpc_asyncio"] = IntentsGrpcAsyncIOTransport - __all__ = ( "IntentsTransport", "IntentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/intents/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/intents/transports/grpc.py index 41b2a08c..a5f67339 100644 --- a/google/cloud/dialogflowcx_v3/services/intents/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/intents/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/intents/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/intents/transports/grpc_asyncio.py index a0b3dd56..8511e4eb 100644 --- a/google/cloud/dialogflowcx_v3/services/intents/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/intents/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/pages/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/pages/transports/__init__.py index ca4547fb..de980d7b 100644 --- a/google/cloud/dialogflowcx_v3/services/pages/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/pages/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = PagesGrpcTransport _transport_registry["grpc_asyncio"] = PagesGrpcAsyncIOTransport - __all__ = ( "PagesTransport", "PagesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/pages/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/pages/transports/grpc.py index 773599fd..141d4bdf 100644 --- a/google/cloud/dialogflowcx_v3/services/pages/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/pages/transports/grpc.py @@ -148,6 +148,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -166,6 +170,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -192,7 +200,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/pages/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/pages/transports/grpc_asyncio.py index b1a41072..6de688fe 100644 --- a/google/cloud/dialogflowcx_v3/services/pages/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/pages/transports/grpc_asyncio.py @@ -193,6 +193,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -211,6 +215,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/__init__.py index 6c0fb025..fc2aea1c 100644 --- a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/__init__.py @@ -30,7 +30,6 @@ _transport_registry["grpc"] = SecuritySettingsServiceGrpcTransport _transport_registry["grpc_asyncio"] = SecuritySettingsServiceGrpcAsyncIOTransport - __all__ = ( "SecuritySettingsServiceTransport", "SecuritySettingsServiceGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc.py index 2fbefcca..b1534262 100644 --- a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc.py @@ -150,6 +150,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -168,6 +172,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -194,7 +202,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc_asyncio.py index 8ad82b74..5110a0da 100644 --- a/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc_asyncio.py @@ -195,6 +195,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -213,6 +217,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/__init__.py index 7ab5a895..606f9116 100644 --- a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/__init__.py @@ -30,7 +30,6 @@ _transport_registry["grpc"] = SessionEntityTypesGrpcTransport _transport_registry["grpc_asyncio"] = SessionEntityTypesGrpcAsyncIOTransport - __all__ = ( "SessionEntityTypesTransport", "SessionEntityTypesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc.py index 8eb837f9..dde1f9ab 100644 --- a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,6 +173,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -195,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc_asyncio.py index 2b672a5f..6ede83ac 100644 --- a/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/sessions/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/sessions/transports/__init__.py index 1e1b2a5e..0ca6c76e 100644 --- a/google/cloud/dialogflowcx_v3/services/sessions/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/sessions/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = SessionsGrpcTransport _transport_registry["grpc_asyncio"] = SessionsGrpcAsyncIOTransport - __all__ = ( "SessionsTransport", "SessionsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc.py index 5922ab35..8c59047a 100644 --- a/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc_asyncio.py index e6c062f6..795c6296 100644 --- a/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/sessions/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/__init__.py index 36c1a1bc..eb2e1618 100644 --- a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/__init__.py @@ -30,7 +30,6 @@ _transport_registry["grpc"] = TransitionRouteGroupsGrpcTransport _transport_registry["grpc_asyncio"] = TransitionRouteGroupsGrpcAsyncIOTransport - __all__ = ( "TransitionRouteGroupsTransport", "TransitionRouteGroupsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc.py index 917e74f8..bed1e905 100644 --- a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,6 +173,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -195,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc_asyncio.py index 316a971e..0a2829e3 100644 --- a/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/services/versions/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/versions/transports/__init__.py index 7801b147..aa4c96b0 100644 --- a/google/cloud/dialogflowcx_v3/services/versions/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/versions/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = VersionsGrpcTransport _transport_registry["grpc_asyncio"] = VersionsGrpcAsyncIOTransport - __all__ = ( "VersionsTransport", "VersionsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/versions/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/versions/transports/grpc.py index 2bf9dfaf..27a1b7fa 100644 --- a/google/cloud/dialogflowcx_v3/services/versions/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/versions/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_versions( diff --git a/google/cloud/dialogflowcx_v3/services/versions/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/versions/transports/grpc_asyncio.py index 4cef08ce..52f2708a 100644 --- a/google/cloud/dialogflowcx_v3/services/versions/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/versions/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_versions( diff --git a/google/cloud/dialogflowcx_v3/services/webhooks/transports/__init__.py b/google/cloud/dialogflowcx_v3/services/webhooks/transports/__init__.py index d41753aa..de5771fe 100644 --- a/google/cloud/dialogflowcx_v3/services/webhooks/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3/services/webhooks/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = WebhooksGrpcTransport _transport_registry["grpc_asyncio"] = WebhooksGrpcAsyncIOTransport - __all__ = ( "WebhooksTransport", "WebhooksGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc.py b/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc.py index dac21a4d..51a87ddd 100644 --- a/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc_asyncio.py index 16acc5a0..16fc6f12 100644 --- a/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3/types/__init__.py b/google/cloud/dialogflowcx_v3/types/__init__.py index 7356eaed..c6f076b4 100644 --- a/google/cloud/dialogflowcx_v3/types/__init__.py +++ b/google/cloud/dialogflowcx_v3/types/__init__.py @@ -59,6 +59,10 @@ VoiceSelectionParams, SynthesizeSpeechConfig, OutputAudioConfig, + AudioEncoding, + SpeechModelVariant, + SsmlVoiceGender, + OutputAudioEncoding, ) from .entity_type import ( EntityType, @@ -88,6 +92,7 @@ CreateIntentRequest, UpdateIntentRequest, DeleteIntentRequest, + IntentView, ) from .security_settings import ( GetSecuritySettingsRequest, @@ -162,7 +167,6 @@ SessionInfo, ) - __all__ = ( "ResponseMessage", "Fulfillment", @@ -201,6 +205,10 @@ "VoiceSelectionParams", "SynthesizeSpeechConfig", "OutputAudioConfig", + "AudioEncoding", + "SpeechModelVariant", + "SsmlVoiceGender", + "OutputAudioEncoding", "EntityType", "ListEntityTypesRequest", "ListEntityTypesResponse", @@ -224,6 +232,7 @@ "CreateIntentRequest", "UpdateIntentRequest", "DeleteIntentRequest", + "IntentView", "GetSecuritySettingsRequest", "UpdateSecuritySettingsRequest", "ListSecuritySettingsRequest", diff --git a/google/cloud/dialogflowcx_v3beta1/__init__.py b/google/cloud/dialogflowcx_v3beta1/__init__.py index 693dda97..3dc967e4 100644 --- a/google/cloud/dialogflowcx_v3beta1/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/__init__.py @@ -245,7 +245,6 @@ "SessionEntityType", "SessionEntityTypesClient", "SessionInfo", - "SessionsClient", "SpeechModelVariant", "SpeechToTextSettings", "SpeechWordInfo", @@ -276,4 +275,5 @@ "WebhookRequest", "WebhookResponse", "WebhooksClient", + "SessionsClient", ) diff --git a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/__init__.py index a87abc01..dfed9192 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = AgentsGrpcTransport _transport_registry["grpc_asyncio"] = AgentsGrpcAsyncIOTransport - __all__ = ( "AgentsTransport", "AgentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc.py index 45c15b55..9a68b3ca 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_agents( diff --git a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc_asyncio.py index 1d38a3b4..62a9bca4 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_agents( diff --git a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/__init__.py index bd6250cb..963959d1 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = EntityTypesGrpcTransport _transport_registry["grpc_asyncio"] = EntityTypesGrpcAsyncIOTransport - __all__ = ( "EntityTypesTransport", "EntityTypesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc.py index 54d83c89..381f4131 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc_asyncio.py index 4ee2bdd2..90201461 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/__init__.py index 14f04446..aff44bcd 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = EnvironmentsGrpcTransport _transport_registry["grpc_asyncio"] = EnvironmentsGrpcAsyncIOTransport - __all__ = ( "EnvironmentsTransport", "EnvironmentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc.py index 3d43e216..9649e5c4 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_environments( diff --git a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc_asyncio.py index 8292443a..f6c47470 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_environments( diff --git a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/__init__.py index d43aadd7..3789db2a 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = FlowsGrpcTransport _transport_registry["grpc_asyncio"] = FlowsGrpcAsyncIOTransport - __all__ = ( "FlowsTransport", "FlowsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc.py index 0def5e99..e277d692 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def create_flow(self) -> Callable[[gcdc_flow.CreateFlowRequest], gcdc_flow.Flow]: diff --git a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc_asyncio.py index fec5fce5..ce42b92f 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def create_flow( diff --git a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/__init__.py index ecbfad6b..41fde33b 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = IntentsGrpcTransport _transport_registry["grpc_asyncio"] = IntentsGrpcAsyncIOTransport - __all__ = ( "IntentsTransport", "IntentsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc.py index 0c52b8b4..6d640e23 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc_asyncio.py index b441089d..dbe9a43c 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/__init__.py index ca4547fb..de980d7b 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = PagesGrpcTransport _transport_registry["grpc_asyncio"] = PagesGrpcAsyncIOTransport - __all__ = ( "PagesTransport", "PagesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc.py index 1f68894e..ebb93d43 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc_asyncio.py index a9fe2225..15048535 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/__init__.py index 7ab5a895..606f9116 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/__init__.py @@ -30,7 +30,6 @@ _transport_registry["grpc"] = SessionEntityTypesGrpcTransport _transport_registry["grpc_asyncio"] = SessionEntityTypesGrpcAsyncIOTransport - __all__ = ( "SessionEntityTypesTransport", "SessionEntityTypesGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc.py index 1f3d4c2f..a628cb1e 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,6 +173,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -195,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc_asyncio.py index 1cc6e983..d4b5ed89 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/services/sessions/async_client.py b/google/cloud/dialogflowcx_v3beta1/services/sessions/async_client.py index b4993bfb..a32034c1 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/sessions/async_client.py +++ b/google/cloud/dialogflowcx_v3beta1/services/sessions/async_client.py @@ -174,11 +174,14 @@ async def detect_intent( timeout: float = None, metadata: Sequence[Tuple[str, str]] = (), ) -> session.DetectIntentResponse: - r"""Processes a natural language query and returns - structured, actionable data as a result. This method is - not idempotent, because it may cause session entity - types to be updated, which in turn might affect results - of future queries. + r"""Processes a natural language query and returns structured, + actionable data as a result. This method is not idempotent, + because it may cause session entity types to be updated, which + in turn might affect results of future queries. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Args: request (:class:`~.session.DetectIntentRequest`): @@ -234,10 +237,14 @@ def streaming_detect_intent( timeout: float = None, metadata: Sequence[Tuple[str, str]] = (), ) -> Awaitable[AsyncIterable[session.StreamingDetectIntentResponse]]: - r"""Processes a natural language query in audio format in - a streaming fashion and returns structured, actionable - data as a result. This method is only available via the - gRPC API (not REST). + r"""Processes a natural language query in audio format in a + streaming fashion and returns structured, actionable data as a + result. This method is only available via the gRPC API (not + REST). + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Args: requests (AsyncIterator[`~.session.StreamingDetectIntentRequest`]): diff --git a/google/cloud/dialogflowcx_v3beta1/services/sessions/client.py b/google/cloud/dialogflowcx_v3beta1/services/sessions/client.py index a116e029..86069279 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/sessions/client.py +++ b/google/cloud/dialogflowcx_v3beta1/services/sessions/client.py @@ -480,11 +480,14 @@ def detect_intent( timeout: float = None, metadata: Sequence[Tuple[str, str]] = (), ) -> session.DetectIntentResponse: - r"""Processes a natural language query and returns - structured, actionable data as a result. This method is - not idempotent, because it may cause session entity - types to be updated, which in turn might affect results - of future queries. + r"""Processes a natural language query and returns structured, + actionable data as a result. This method is not idempotent, + because it may cause session entity types to be updated, which + in turn might affect results of future queries. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Args: request (:class:`~.session.DetectIntentRequest`): @@ -535,10 +538,14 @@ def streaming_detect_intent( timeout: float = None, metadata: Sequence[Tuple[str, str]] = (), ) -> Iterable[session.StreamingDetectIntentResponse]: - r"""Processes a natural language query in audio format in - a streaming fashion and returns structured, actionable - data as a result. This method is only available via the - gRPC API (not REST). + r"""Processes a natural language query in audio format in a + streaming fashion and returns structured, actionable data as a + result. This method is only available via the gRPC API (not + REST). + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Args: requests (Iterator[`~.session.StreamingDetectIntentRequest`]): diff --git a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/__init__.py index 1e1b2a5e..0ca6c76e 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = SessionsGrpcTransport _transport_registry["grpc_asyncio"] = SessionsGrpcAsyncIOTransport - __all__ = ( "SessionsTransport", "SessionsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc.py index e9943996..6f8f0b17 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -238,11 +246,14 @@ def detect_intent( ) -> Callable[[session.DetectIntentRequest], session.DetectIntentResponse]: r"""Return a callable for the detect intent method over gRPC. - Processes a natural language query and returns - structured, actionable data as a result. This method is - not idempotent, because it may cause session entity - types to be updated, which in turn might affect results - of future queries. + Processes a natural language query and returns structured, + actionable data as a result. This method is not idempotent, + because it may cause session entity types to be updated, which + in turn might affect results of future queries. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Returns: Callable[[~.DetectIntentRequest], @@ -270,10 +281,14 @@ def streaming_detect_intent( ]: r"""Return a callable for the streaming detect intent method over gRPC. - Processes a natural language query in audio format in - a streaming fashion and returns structured, actionable - data as a result. This method is only available via the - gRPC API (not REST). + Processes a natural language query in audio format in a + streaming fashion and returns structured, actionable data as a + result. This method is only available via the gRPC API (not + REST). + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Returns: Callable[[~.StreamingDetectIntentRequest], diff --git a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc_asyncio.py index 8daf8f78..38ce2091 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -244,11 +252,14 @@ def detect_intent( ]: r"""Return a callable for the detect intent method over gRPC. - Processes a natural language query and returns - structured, actionable data as a result. This method is - not idempotent, because it may cause session entity - types to be updated, which in turn might affect results - of future queries. + Processes a natural language query and returns structured, + actionable data as a result. This method is not idempotent, + because it may cause session entity types to be updated, which + in turn might affect results of future queries. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Returns: Callable[[~.DetectIntentRequest], @@ -277,10 +288,14 @@ def streaming_detect_intent( ]: r"""Return a callable for the streaming detect intent method over gRPC. - Processes a natural language query in audio format in - a streaming fashion and returns structured, actionable - data as a result. This method is only available via the - gRPC API (not REST). + Processes a natural language query in audio format in a + streaming fashion and returns structured, actionable data as a + result. This method is only available via the gRPC API (not + REST). + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. Returns: Callable[[~.StreamingDetectIntentRequest], diff --git a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/__init__.py index 36c1a1bc..eb2e1618 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/__init__.py @@ -30,7 +30,6 @@ _transport_registry["grpc"] = TransitionRouteGroupsGrpcTransport _transport_registry["grpc_asyncio"] = TransitionRouteGroupsGrpcAsyncIOTransport - __all__ = ( "TransitionRouteGroupsTransport", "TransitionRouteGroupsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc.py index 5898945a..3002b73c 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,6 +173,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -195,7 +203,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc_asyncio.py index 38197156..66167298 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/__init__.py index 7801b147..aa4c96b0 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = VersionsGrpcTransport _transport_registry["grpc_asyncio"] = VersionsGrpcAsyncIOTransport - __all__ = ( "VersionsTransport", "VersionsGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc.py index e7da5ca1..226cd5f1 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc.py @@ -151,6 +151,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -169,9 +173,14 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] + self._operations_client = None # Run the base constructor. super().__init__( @@ -195,7 +204,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If @@ -242,13 +251,11 @@ def operations_client(self) -> operations_v1.OperationsClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsClient( - self.grpc_channel - ) + if self._operations_client is None: + self._operations_client = operations_v1.OperationsClient(self.grpc_channel) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_versions( diff --git a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc_asyncio.py index 97ffe378..72ab543e 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc_asyncio.py @@ -196,6 +196,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -214,6 +218,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. @@ -227,6 +235,7 @@ def __init__( ) self._stubs = {} + self._operations_client = None @property def grpc_channel(self) -> aio.Channel: @@ -246,13 +255,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient: client. """ # Sanity check: Only create a new client if we do not already have one. - if "operations_client" not in self.__dict__: - self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient( + if self._operations_client is None: + self._operations_client = operations_v1.OperationsAsyncClient( self.grpc_channel ) # Return the client from cache. - return self.__dict__["operations_client"] + return self._operations_client @property def list_versions( diff --git a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/__init__.py b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/__init__.py index d41753aa..de5771fe 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/__init__.py @@ -28,7 +28,6 @@ _transport_registry["grpc"] = WebhooksGrpcTransport _transport_registry["grpc_asyncio"] = WebhooksGrpcAsyncIOTransport - __all__ = ( "WebhooksTransport", "WebhooksGrpcTransport", diff --git a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc.py b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc.py index 3125edd2..0506a703 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc.py +++ b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc.py @@ -149,6 +149,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -167,6 +171,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._stubs = {} # type: Dict[str, Callable] @@ -193,7 +201,7 @@ def create_channel( ) -> grpc.Channel: """Create and return a gRPC channel object. Args: - address (Optionsl[str]): The host for the channel to use. + address (Optional[str]): The host for the channel to use. credentials (Optional[~.Credentials]): The authorization credentials to attach to requests. These credentials identify this application to the service. If diff --git a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc_asyncio.py b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc_asyncio.py index 04ea7da1..b781c7d5 100644 --- a/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc_asyncio.py +++ b/google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc_asyncio.py @@ -194,6 +194,10 @@ def __init__( ssl_credentials=ssl_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) self._ssl_channel_credentials = ssl_credentials else: @@ -212,6 +216,10 @@ def __init__( ssl_credentials=ssl_channel_credentials, scopes=scopes or self.AUTH_SCOPES, quota_project_id=quota_project_id, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) # Run the base constructor. diff --git a/google/cloud/dialogflowcx_v3beta1/types/__init__.py b/google/cloud/dialogflowcx_v3beta1/types/__init__.py index c08c5d09..b4e37de5 100644 --- a/google/cloud/dialogflowcx_v3beta1/types/__init__.py +++ b/google/cloud/dialogflowcx_v3beta1/types/__init__.py @@ -59,6 +59,10 @@ VoiceSelectionParams, SynthesizeSpeechConfig, OutputAudioConfig, + AudioEncoding, + SpeechModelVariant, + SsmlVoiceGender, + OutputAudioEncoding, ) from .entity_type import ( EntityType, @@ -88,6 +92,7 @@ CreateIntentRequest, UpdateIntentRequest, DeleteIntentRequest, + IntentView, ) from .session_entity_type import ( SessionEntityType, @@ -153,7 +158,6 @@ SessionInfo, ) - __all__ = ( "ResponseMessage", "Fulfillment", @@ -192,6 +196,10 @@ "VoiceSelectionParams", "SynthesizeSpeechConfig", "OutputAudioConfig", + "AudioEncoding", + "SpeechModelVariant", + "SsmlVoiceGender", + "OutputAudioEncoding", "EntityType", "ListEntityTypesRequest", "ListEntityTypesResponse", @@ -215,6 +223,7 @@ "CreateIntentRequest", "UpdateIntentRequest", "DeleteIntentRequest", + "IntentView", "SessionEntityType", "ListSessionEntityTypesRequest", "ListSessionEntityTypesResponse", diff --git a/google/cloud/dialogflowcx_v3beta1/types/response_message.py b/google/cloud/dialogflowcx_v3beta1/types/response_message.py index ad0e2726..72a21517 100644 --- a/google/cloud/dialogflowcx_v3beta1/types/response_message.py +++ b/google/cloud/dialogflowcx_v3beta1/types/response_message.py @@ -180,6 +180,32 @@ class OutputAudioText(proto.Message): allow_playback_interruption = proto.Field(proto.BOOL, number=3) + class PlayAudio(proto.Message): + r"""Specifies an audio clip to be played by the client as part of + the response. + + Attributes: + audio_uri (str): + Required. URI of the audio clip. Dialogflow + does not impose any validation on this value. It + is specific to the client that reads it. + allow_playback_interruption (bool): + Output only. Whether the playback of this + message can be interrupted by the end user's + speech and the client can then starts the next + Dialogflow request. + """ + + audio_uri = proto.Field(proto.STRING, number=1) + + allow_playback_interruption = proto.Field(proto.BOOL, number=2) + + class EndInteraction(proto.Message): + r"""Indicates that interaction with the Dialogflow agent has + ended. This message is generated by Dialogflow only and not + supposed to be defined by the user. + """ + class MixedAudio(proto.Message): r"""Represents an audio message that is composed of both segments synthesized from the Dialogflow agent prompts and ones hosted @@ -223,32 +249,6 @@ class Segment(proto.Message): proto.MESSAGE, number=1, message="ResponseMessage.MixedAudio.Segment", ) - class EndInteraction(proto.Message): - r"""Indicates that interaction with the Dialogflow agent has - ended. This message is generated by Dialogflow only and not - supposed to be defined by the user. - """ - - class PlayAudio(proto.Message): - r"""Specifies an audio clip to be played by the client as part of - the response. - - Attributes: - audio_uri (str): - Required. URI of the audio clip. Dialogflow - does not impose any validation on this value. It - is specific to the client that reads it. - allow_playback_interruption (bool): - Output only. Whether the playback of this - message can be interrupted by the end user's - speech and the client can then starts the next - Dialogflow request. - """ - - audio_uri = proto.Field(proto.STRING, number=1) - - allow_playback_interruption = proto.Field(proto.BOOL, number=2) - text = proto.Field(proto.MESSAGE, number=1, oneof="message", message=Text,) payload = proto.Field( diff --git a/google/cloud/dialogflowcx_v3beta1/types/session.py b/google/cloud/dialogflowcx_v3beta1/types/session.py index 98a33ff2..593e1aff 100644 --- a/google/cloud/dialogflowcx_v3beta1/types/session.py +++ b/google/cloud/dialogflowcx_v3beta1/types/session.py @@ -73,6 +73,10 @@ class DetectIntentRequest(proto.Message): For more information, see the `sessions guide `__. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. query_params (~.gcdc_session.QueryParameters): The parameters of this query. query_input (~.gcdc_session.QueryInput): @@ -185,6 +189,10 @@ class StreamingDetectIntentRequest(proto.Message): For more information, see the `sessions guide `__. + + Note: Always use agent versions for production traffic. See + `Versions and + environments `__. query_params (~.gcdc_session.QueryParameters): The parameters of this query. query_input (~.gcdc_session.QueryInput): @@ -386,6 +394,19 @@ class QueryParameters(proto.Message): Configures whether sentiment analysis should be performed. If not provided, sentiment analysis is not performed. + webhook_headers (Sequence[~.gcdc_session.QueryParameters.WebhookHeadersEntry]): + This field can be used to pass HTTP headers + for a webhook call. These headers will be sent + to webhook along with the headers that have been + configured through Dialogflow web console. The + headers defined within this field will overwrite + the headers configured through Dialogflow + console if there is a conflict. Header names are + case-insensitive. Google's specified headers are + not allowed. Including: "Host", "Content- + Length", "Connection", "From", "User-Agent", + "Accept-Encoding", "If-Modified-Since", "If- + None-Match", "X-Forwarded-For", etc. """ time_zone = proto.Field(proto.STRING, number=1) @@ -402,6 +423,8 @@ class QueryParameters(proto.Message): analyze_query_text_sentiment = proto.Field(proto.BOOL, number=8) + webhook_headers = proto.MapField(proto.STRING, proto.STRING, number=10) + class QueryInput(proto.Message): r"""Represents the query input. It can contain one of: diff --git a/synth.metadata b/synth.metadata index 119ec986..0cd0513b 100644 --- a/synth.metadata +++ b/synth.metadata @@ -3,22 +3,30 @@ { "git": { "name": ".", - "remote": "git@github.com:googleapis/python-dialogflow-cx", - "sha": "58c92adeaecfe333cb46aa4ff42bb703436e50f3" + "remote": "https://github.com/googleapis/python-dialogflow-cx.git", + "sha": "6a49271c10991a954e113e935afc7554d77f5ac4" + } + }, + { + "git": { + "name": "googleapis", + "remote": "https://github.com/googleapis/googleapis.git", + "sha": "5256ab60f3d396a3d1bd393043776936b9651c5b", + "internalRef": "347703845" } }, { "git": { "name": "synthtool", "remote": "https://github.com/googleapis/synthtool.git", - "sha": "5d11bd2888c38ce1fb6fa6bf25494a4219a73928" + "sha": "aa255b15d52b6d8950cca48cfdf58f7d27a60c8a" } }, { "git": { "name": "synthtool", "remote": "https://github.com/googleapis/synthtool.git", - "sha": "5d11bd2888c38ce1fb6fa6bf25494a4219a73928" + "sha": "aa255b15d52b6d8950cca48cfdf58f7d27a60c8a" } } ], @@ -41,5 +49,322 @@ "generator": "bazel" } } + ], + "generatedFiles": [ + ".flake8", + ".github/CONTRIBUTING.md", + ".github/ISSUE_TEMPLATE/bug_report.md", + ".github/ISSUE_TEMPLATE/feature_request.md", + ".github/ISSUE_TEMPLATE/support_request.md", + ".github/PULL_REQUEST_TEMPLATE.md", + ".github/release-please.yml", + ".github/snippet-bot.yml", + ".gitignore", + ".kokoro/build.sh", + ".kokoro/continuous/common.cfg", + ".kokoro/continuous/continuous.cfg", + ".kokoro/docker/docs/Dockerfile", + ".kokoro/docker/docs/fetch_gpg_keys.sh", + ".kokoro/docs/common.cfg", + ".kokoro/docs/docs-presubmit.cfg", + ".kokoro/docs/docs.cfg", + ".kokoro/populate-secrets.sh", + ".kokoro/presubmit/common.cfg", + ".kokoro/presubmit/presubmit.cfg", + ".kokoro/publish-docs.sh", + ".kokoro/release.sh", + ".kokoro/release/common.cfg", + ".kokoro/release/release.cfg", + ".kokoro/samples/lint/common.cfg", + ".kokoro/samples/lint/continuous.cfg", + ".kokoro/samples/lint/periodic.cfg", + ".kokoro/samples/lint/presubmit.cfg", + ".kokoro/samples/python3.6/common.cfg", + ".kokoro/samples/python3.6/continuous.cfg", + ".kokoro/samples/python3.6/periodic.cfg", + ".kokoro/samples/python3.6/presubmit.cfg", + ".kokoro/samples/python3.7/common.cfg", + ".kokoro/samples/python3.7/continuous.cfg", + ".kokoro/samples/python3.7/periodic.cfg", + ".kokoro/samples/python3.7/presubmit.cfg", + ".kokoro/samples/python3.8/common.cfg", + ".kokoro/samples/python3.8/continuous.cfg", + ".kokoro/samples/python3.8/periodic.cfg", + ".kokoro/samples/python3.8/presubmit.cfg", + ".kokoro/test-samples.sh", + ".kokoro/trampoline.sh", + ".kokoro/trampoline_v2.sh", + ".pre-commit-config.yaml", + ".trampolinerc", + "CODE_OF_CONDUCT.md", + "CONTRIBUTING.rst", + "LICENSE", + "MANIFEST.in", + "docs/_static/custom.css", + "docs/_templates/layout.html", + "docs/conf.py", + "docs/dialogflowcx_v3/services.rst", + "docs/dialogflowcx_v3/types.rst", + "docs/dialogflowcx_v3beta1/services.rst", + "docs/dialogflowcx_v3beta1/types.rst", + "docs/multiprocessing.rst", + "google/cloud/dialogflowcx/__init__.py", + "google/cloud/dialogflowcx/py.typed", + "google/cloud/dialogflowcx_v3/__init__.py", + "google/cloud/dialogflowcx_v3/py.typed", + "google/cloud/dialogflowcx_v3/services/__init__.py", + "google/cloud/dialogflowcx_v3/services/agents/__init__.py", + "google/cloud/dialogflowcx_v3/services/agents/async_client.py", + "google/cloud/dialogflowcx_v3/services/agents/client.py", + "google/cloud/dialogflowcx_v3/services/agents/pagers.py", + "google/cloud/dialogflowcx_v3/services/agents/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/agents/transports/base.py", + "google/cloud/dialogflowcx_v3/services/agents/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/agents/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/entity_types/__init__.py", + "google/cloud/dialogflowcx_v3/services/entity_types/async_client.py", + "google/cloud/dialogflowcx_v3/services/entity_types/client.py", + "google/cloud/dialogflowcx_v3/services/entity_types/pagers.py", + "google/cloud/dialogflowcx_v3/services/entity_types/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/entity_types/transports/base.py", + "google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/entity_types/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/environments/__init__.py", + "google/cloud/dialogflowcx_v3/services/environments/async_client.py", + "google/cloud/dialogflowcx_v3/services/environments/client.py", + "google/cloud/dialogflowcx_v3/services/environments/pagers.py", + "google/cloud/dialogflowcx_v3/services/environments/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/environments/transports/base.py", + "google/cloud/dialogflowcx_v3/services/environments/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/environments/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/flows/__init__.py", + "google/cloud/dialogflowcx_v3/services/flows/async_client.py", + "google/cloud/dialogflowcx_v3/services/flows/client.py", + "google/cloud/dialogflowcx_v3/services/flows/pagers.py", + "google/cloud/dialogflowcx_v3/services/flows/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/flows/transports/base.py", + "google/cloud/dialogflowcx_v3/services/flows/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/flows/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/intents/__init__.py", + "google/cloud/dialogflowcx_v3/services/intents/async_client.py", + "google/cloud/dialogflowcx_v3/services/intents/client.py", + "google/cloud/dialogflowcx_v3/services/intents/pagers.py", + "google/cloud/dialogflowcx_v3/services/intents/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/intents/transports/base.py", + "google/cloud/dialogflowcx_v3/services/intents/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/intents/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/pages/__init__.py", + "google/cloud/dialogflowcx_v3/services/pages/async_client.py", + "google/cloud/dialogflowcx_v3/services/pages/client.py", + "google/cloud/dialogflowcx_v3/services/pages/pagers.py", + "google/cloud/dialogflowcx_v3/services/pages/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/pages/transports/base.py", + "google/cloud/dialogflowcx_v3/services/pages/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/pages/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/__init__.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/async_client.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/client.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/pagers.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/transports/base.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/security_settings_service/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/__init__.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/async_client.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/client.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/pagers.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/transports/base.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/session_entity_types/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/sessions/__init__.py", + "google/cloud/dialogflowcx_v3/services/sessions/async_client.py", + "google/cloud/dialogflowcx_v3/services/sessions/client.py", + "google/cloud/dialogflowcx_v3/services/sessions/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/sessions/transports/base.py", + "google/cloud/dialogflowcx_v3/services/sessions/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/sessions/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/__init__.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/async_client.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/client.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/pagers.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/base.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/transition_route_groups/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/versions/__init__.py", + "google/cloud/dialogflowcx_v3/services/versions/async_client.py", + "google/cloud/dialogflowcx_v3/services/versions/client.py", + "google/cloud/dialogflowcx_v3/services/versions/pagers.py", + "google/cloud/dialogflowcx_v3/services/versions/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/versions/transports/base.py", + "google/cloud/dialogflowcx_v3/services/versions/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/versions/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/services/webhooks/__init__.py", + "google/cloud/dialogflowcx_v3/services/webhooks/async_client.py", + "google/cloud/dialogflowcx_v3/services/webhooks/client.py", + "google/cloud/dialogflowcx_v3/services/webhooks/pagers.py", + "google/cloud/dialogflowcx_v3/services/webhooks/transports/__init__.py", + "google/cloud/dialogflowcx_v3/services/webhooks/transports/base.py", + "google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc.py", + "google/cloud/dialogflowcx_v3/services/webhooks/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3/types/__init__.py", + "google/cloud/dialogflowcx_v3/types/agent.py", + "google/cloud/dialogflowcx_v3/types/audio_config.py", + "google/cloud/dialogflowcx_v3/types/entity_type.py", + "google/cloud/dialogflowcx_v3/types/environment.py", + "google/cloud/dialogflowcx_v3/types/flow.py", + "google/cloud/dialogflowcx_v3/types/fulfillment.py", + "google/cloud/dialogflowcx_v3/types/intent.py", + "google/cloud/dialogflowcx_v3/types/page.py", + "google/cloud/dialogflowcx_v3/types/response_message.py", + "google/cloud/dialogflowcx_v3/types/security_settings.py", + "google/cloud/dialogflowcx_v3/types/session.py", + "google/cloud/dialogflowcx_v3/types/session_entity_type.py", + "google/cloud/dialogflowcx_v3/types/transition_route_group.py", + "google/cloud/dialogflowcx_v3/types/version.py", + "google/cloud/dialogflowcx_v3/types/webhook.py", + "google/cloud/dialogflowcx_v3beta1/__init__.py", + "google/cloud/dialogflowcx_v3beta1/py.typed", + "google/cloud/dialogflowcx_v3beta1/services/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/client.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/agents/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/client.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/entity_types/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/client.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/environments/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/client.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/flows/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/client.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/intents/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/client.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/pages/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/client.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/session_entity_types/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/client.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/sessions/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/client.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/transition_route_groups/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/client.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/versions/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/async_client.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/client.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/pagers.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/__init__.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/base.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc.py", + "google/cloud/dialogflowcx_v3beta1/services/webhooks/transports/grpc_asyncio.py", + "google/cloud/dialogflowcx_v3beta1/types/__init__.py", + "google/cloud/dialogflowcx_v3beta1/types/agent.py", + "google/cloud/dialogflowcx_v3beta1/types/audio_config.py", + "google/cloud/dialogflowcx_v3beta1/types/entity_type.py", + "google/cloud/dialogflowcx_v3beta1/types/environment.py", + "google/cloud/dialogflowcx_v3beta1/types/flow.py", + "google/cloud/dialogflowcx_v3beta1/types/fulfillment.py", + "google/cloud/dialogflowcx_v3beta1/types/intent.py", + "google/cloud/dialogflowcx_v3beta1/types/page.py", + "google/cloud/dialogflowcx_v3beta1/types/response_message.py", + "google/cloud/dialogflowcx_v3beta1/types/session.py", + "google/cloud/dialogflowcx_v3beta1/types/session_entity_type.py", + "google/cloud/dialogflowcx_v3beta1/types/transition_route_group.py", + "google/cloud/dialogflowcx_v3beta1/types/version.py", + "google/cloud/dialogflowcx_v3beta1/types/webhook.py", + "mypy.ini", + "noxfile.py", + "renovate.json", + "scripts/decrypt-secrets.sh", + "scripts/readme-gen/readme_gen.py", + "scripts/readme-gen/templates/README.tmpl.rst", + "scripts/readme-gen/templates/auth.tmpl.rst", + "scripts/readme-gen/templates/auth_api_key.tmpl.rst", + "scripts/readme-gen/templates/install_deps.tmpl.rst", + "scripts/readme-gen/templates/install_portaudio.tmpl.rst", + "setup.cfg", + "testing/.gitignore", + "tests/unit/gapic/dialogflowcx_v3/__init__.py", + "tests/unit/gapic/dialogflowcx_v3/test_agents.py", + "tests/unit/gapic/dialogflowcx_v3/test_entity_types.py", + "tests/unit/gapic/dialogflowcx_v3/test_environments.py", + "tests/unit/gapic/dialogflowcx_v3/test_flows.py", + "tests/unit/gapic/dialogflowcx_v3/test_intents.py", + "tests/unit/gapic/dialogflowcx_v3/test_pages.py", + "tests/unit/gapic/dialogflowcx_v3/test_security_settings_service.py", + "tests/unit/gapic/dialogflowcx_v3/test_session_entity_types.py", + "tests/unit/gapic/dialogflowcx_v3/test_sessions.py", + "tests/unit/gapic/dialogflowcx_v3/test_transition_route_groups.py", + "tests/unit/gapic/dialogflowcx_v3/test_versions.py", + "tests/unit/gapic/dialogflowcx_v3/test_webhooks.py", + "tests/unit/gapic/dialogflowcx_v3beta1/__init__.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_agents.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_entity_types.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_environments.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_flows.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_intents.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_pages.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_session_entity_types.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_sessions.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_transition_route_groups.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_versions.py", + "tests/unit/gapic/dialogflowcx_v3beta1/test_webhooks.py" ] } \ No newline at end of file diff --git a/tests/unit/gapic/dialogflowcx_v3/test_agents.py b/tests/unit/gapic/dialogflowcx_v3/test_agents.py index 6ae40d30..f58083c2 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_agents.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_agents.py @@ -2123,6 +2123,10 @@ def test_agents_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2164,6 +2168,10 @@ def test_agents_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_entity_types.py b/tests/unit/gapic/dialogflowcx_v3/test_entity_types.py index c2dc6f59..22ecbedb 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_entity_types.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_entity_types.py @@ -1968,6 +1968,10 @@ def test_entity_types_transport_channel_mtls_with_client_cert_source(transport_c ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2009,6 +2013,10 @@ def test_entity_types_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_environments.py b/tests/unit/gapic/dialogflowcx_v3/test_environments.py index b193e979..4f05cd0d 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_environments.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_environments.py @@ -2246,6 +2246,10 @@ def test_environments_transport_channel_mtls_with_client_cert_source(transport_c ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2287,6 +2291,10 @@ def test_environments_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_flows.py b/tests/unit/gapic/dialogflowcx_v3/test_flows.py index 3de55597..e98c1fe9 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_flows.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_flows.py @@ -1957,6 +1957,10 @@ def test_flows_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1998,6 +2002,10 @@ def test_flows_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_intents.py b/tests/unit/gapic/dialogflowcx_v3/test_intents.py index f92d9461..5735461e 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_intents.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_intents.py @@ -1815,6 +1815,10 @@ def test_intents_transport_channel_mtls_with_client_cert_source(transport_class) ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1856,6 +1860,10 @@ def test_intents_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_pages.py b/tests/unit/gapic/dialogflowcx_v3/test_pages.py index 11479877..63101426 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_pages.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_pages.py @@ -1762,6 +1762,10 @@ def test_pages_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1803,6 +1807,10 @@ def test_pages_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_security_settings_service.py b/tests/unit/gapic/dialogflowcx_v3/test_security_settings_service.py index d7ae1702..560e9732 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_security_settings_service.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_security_settings_service.py @@ -2211,6 +2211,10 @@ def test_security_settings_service_transport_channel_mtls_with_client_cert_sourc ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2255,6 +2259,10 @@ def test_security_settings_service_transport_channel_mtls_with_adc(transport_cla ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_session_entity_types.py b/tests/unit/gapic/dialogflowcx_v3/test_session_entity_types.py index 4abcbe55..07e17479 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_session_entity_types.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_session_entity_types.py @@ -2059,6 +2059,10 @@ def test_session_entity_types_transport_channel_mtls_with_client_cert_source( ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2103,6 +2107,10 @@ def test_session_entity_types_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_sessions.py b/tests/unit/gapic/dialogflowcx_v3/test_sessions.py index bfa203f9..9dd954d5 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_sessions.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_sessions.py @@ -1136,6 +1136,10 @@ def test_sessions_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1177,6 +1181,10 @@ def test_sessions_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_transition_route_groups.py b/tests/unit/gapic/dialogflowcx_v3/test_transition_route_groups.py index efcf25c4..71459521 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_transition_route_groups.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_transition_route_groups.py @@ -2105,6 +2105,10 @@ def test_transition_route_groups_transport_channel_mtls_with_client_cert_source( ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2149,6 +2153,10 @@ def test_transition_route_groups_transport_channel_mtls_with_adc(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_versions.py b/tests/unit/gapic/dialogflowcx_v3/test_versions.py index 8693eca7..75312e56 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_versions.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_versions.py @@ -1994,6 +1994,10 @@ def test_versions_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2035,6 +2039,10 @@ def test_versions_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3/test_webhooks.py b/tests/unit/gapic/dialogflowcx_v3/test_webhooks.py index ef861daf..b93c373b 100644 --- a/tests/unit/gapic/dialogflowcx_v3/test_webhooks.py +++ b/tests/unit/gapic/dialogflowcx_v3/test_webhooks.py @@ -1804,6 +1804,10 @@ def test_webhooks_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1845,6 +1849,10 @@ def test_webhooks_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_agents.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_agents.py index b0973ffb..857e7c8e 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_agents.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_agents.py @@ -2123,6 +2123,10 @@ def test_agents_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2164,6 +2168,10 @@ def test_agents_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_entity_types.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_entity_types.py index e08b0e64..84b2a6ae 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_entity_types.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_entity_types.py @@ -1970,6 +1970,10 @@ def test_entity_types_transport_channel_mtls_with_client_cert_source(transport_c ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2011,6 +2015,10 @@ def test_entity_types_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_environments.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_environments.py index 07b0315b..ba4b446e 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_environments.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_environments.py @@ -2248,6 +2248,10 @@ def test_environments_transport_channel_mtls_with_client_cert_source(transport_c ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2289,6 +2293,10 @@ def test_environments_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_flows.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_flows.py index 3b7366c2..b32e81fd 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_flows.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_flows.py @@ -1957,6 +1957,10 @@ def test_flows_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1998,6 +2002,10 @@ def test_flows_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_intents.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_intents.py index 3845195d..4bfab502 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_intents.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_intents.py @@ -1815,6 +1815,10 @@ def test_intents_transport_channel_mtls_with_client_cert_source(transport_class) ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1856,6 +1860,10 @@ def test_intents_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_pages.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_pages.py index 91ed58d2..dc622e71 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_pages.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_pages.py @@ -1762,6 +1762,10 @@ def test_pages_transport_channel_mtls_with_client_cert_source(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1803,6 +1807,10 @@ def test_pages_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_session_entity_types.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_session_entity_types.py index 8f4191d3..1b7c818e 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_session_entity_types.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_session_entity_types.py @@ -2059,6 +2059,10 @@ def test_session_entity_types_transport_channel_mtls_with_client_cert_source( ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2103,6 +2107,10 @@ def test_session_entity_types_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_sessions.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_sessions.py index a8a4eb99..3091acbe 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_sessions.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_sessions.py @@ -1136,6 +1136,10 @@ def test_sessions_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1177,6 +1181,10 @@ def test_sessions_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_transition_route_groups.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_transition_route_groups.py index 5dd04fb9..bf09edfe 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_transition_route_groups.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_transition_route_groups.py @@ -2107,6 +2107,10 @@ def test_transition_route_groups_transport_channel_mtls_with_client_cert_source( ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2151,6 +2155,10 @@ def test_transition_route_groups_transport_channel_mtls_with_adc(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_versions.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_versions.py index 13d7b5f8..bcd78804 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_versions.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_versions.py @@ -1994,6 +1994,10 @@ def test_versions_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -2035,6 +2039,10 @@ def test_versions_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel diff --git a/tests/unit/gapic/dialogflowcx_v3beta1/test_webhooks.py b/tests/unit/gapic/dialogflowcx_v3beta1/test_webhooks.py index b4c3031b..f2a6462b 100644 --- a/tests/unit/gapic/dialogflowcx_v3beta1/test_webhooks.py +++ b/tests/unit/gapic/dialogflowcx_v3beta1/test_webhooks.py @@ -1804,6 +1804,10 @@ def test_webhooks_transport_channel_mtls_with_client_cert_source(transport_class ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel assert transport._ssl_channel_credentials == mock_ssl_cred @@ -1845,6 +1849,10 @@ def test_webhooks_transport_channel_mtls_with_adc(transport_class): ), ssl_credentials=mock_ssl_cred, quota_project_id=None, + options=[ + ("grpc.max_send_message_length", -1), + ("grpc.max_receive_message_length", -1), + ], ) assert transport.grpc_channel == mock_grpc_channel