regenerate locally with legacylibrarian

Author: jskeet

.librarian/state.yaml

@@ -999,7 +999,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-ces
     version: 0.2.0
-    last_generated_commit: 6df3ecf4fd43b64826de6a477d1a535ec18b0d7c
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/ces/v1
         service_config: ces_v1.yaml
@@ -1280,7 +1280,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-databasecenter
     version: 0.6.0
-    last_generated_commit: 6df3ecf4fd43b64826de6a477d1a535ec18b0d7c
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/databasecenter/v1beta
         service_config: databasecenter_v1beta.yaml
@@ -1551,7 +1551,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-dialogflow-cx
     version: 2.4.0
-    last_generated_commit: 256b575f6915282b20795c13414b21f2c0af65db
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/dialogflow/cx/v3
         service_config: dialogflow_v3.yaml
@@ -1567,7 +1567,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-discoveryengine
     version: 0.17.0
-    last_generated_commit: 256b575f6915282b20795c13414b21f2c0af65db
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/discoveryengine/v1
         service_config: discoveryengine_v1.yaml
@@ -1585,7 +1585,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-dlp
     version: 3.34.0
-    last_generated_commit: 9a477cd3c26a704130e2a2fb44a40281d9312e4c
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/privacy/dlp/v2
         service_config: dlp_v2.yaml
@@ -1697,7 +1697,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-error-reporting
     version: 1.14.0
-    last_generated_commit: ebfdba37e54d9cd3e78380d226c2c4ab5a5f7fd4
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/devtools/clouderrorreporting/v1beta1
         service_config: clouderrorreporting_v1beta1.yaml
@@ -1804,7 +1804,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-firestore
     version: 2.25.0
-    last_generated_commit: 6df3ecf4fd43b64826de6a477d1a535ec18b0d7c
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/firestore/admin/v1
         service_config: firestore_v1.yaml
@@ -2179,7 +2179,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-logging
     version: 3.14.0
-    last_generated_commit: 69bf99a9d0910fa86c3c5867ea357aa004dfcc55
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/logging/v2
         service_config: logging_v2.yaml
@@ -2926,7 +2926,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-run
     version: 0.15.0
-    last_generated_commit: 87e3579c041a50f985f8de71e9494c8fc85d520b
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/run/v2
         service_config: run_v2.yaml
@@ -3355,7 +3355,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-trace
     version: 1.18.0
-    last_generated_commit: 3322511885371d2b2253f209ccc3aa60d4100cfd
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/devtools/cloudtrace/v2
         service_config: cloudtrace_v2.yaml
@@ -3499,7 +3499,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-cloud-visionai
     version: 0.4.0
-    last_generated_commit: 9eea40c74d97622bb0aa406dd313409a376cc73b
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/cloud/visionai/v1alpha1
         service_config: visionai_v1alpha1.yaml
@@ -3748,7 +3748,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-maps-places
     version: 0.7.0
-    last_generated_commit: 6df3ecf4fd43b64826de6a477d1a535ec18b0d7c
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/maps/places/v1
         service_config: places_v1.yaml
@@ -3827,7 +3827,7 @@ libraries:
     tag_format: '{id}-v{version}'
   - id: google-shopping-merchant-accounts
     version: 1.3.0
-    last_generated_commit: 256b575f6915282b20795c13414b21f2c0af65db
+    last_generated_commit: 28d90ca63e8c8bf06278afab07c5890aabe20ad3
     apis:
       - path: google/shopping/merchant/accounts/v1
         service_config: merchantapi_v1.yaml

packages/google-cloud-ces/google/cloud/ces_v1beta/__init__.py

@@ -95,6 +95,7 @@
     ListToolsRequest,
     ListToolsResponse,
     OperationMetadata,
+    QualityReport,
     RestoreAppVersionRequest,
     RestoreAppVersionResponse,
     UpdateAgentRequest,
@@ -563,6 +564,7 @@ def _get_version(dependency_name):
     "PersonaRunConfig",
     "PythonCodeCondition",
     "PythonFunction",
+    "QualityReport",
     "RecognitionResult",
     "RedactionConfig",
     "RestoreAppVersionRequest",

packages/google-cloud-ces/google/cloud/ces_v1beta/gapic_metadata.json

@@ -1272,6 +1272,11 @@
               "methods": [
                 "run_session"
               ]
+            },
+            "StreamRunSession": {
+              "methods": [
+                "stream_run_session"
+              ]
             }
           }
         },
@@ -1287,6 +1292,11 @@
               "methods": [
                 "run_session"
               ]
+            },
+            "StreamRunSession": {
+              "methods": [
+                "stream_run_session"
+              ]
             }
           }
         },
@@ -1302,6 +1312,11 @@
               "methods": [
                 "run_session"
               ]
+            },
+            "StreamRunSession": {
+              "methods": [
+                "stream_run_session"
+              ]
             }
           }
         }

packages/google-cloud-ces/google/cloud/ces_v1beta/services/session_service/async_client.py

@@ -314,7 +314,7 @@ async def run_session(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> session_service.RunSessionResponse:
-        r"""Initiates a single turn interaction with the CES
+        r"""Initiates a single-turn interaction with the CES
         agent within a session.
 
         .. code-block:: python
@@ -402,6 +402,111 @@ async def sample_run_session():
         # Done; return the response.
         return response
 
+    def stream_run_session(
+        self,
+        request: Optional[Union[session_service.RunSessionRequest, dict]] = None,
+        *,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
+        timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
+    ) -> Awaitable[AsyncIterable[session_service.RunSessionResponse]]:
+        r"""Initiates a single-turn interaction with the CES agent. Uses
+        server-side streaming to deliver incremental results and partial
+        responses as they are generated.
+
+        By default, complete responses (e.g., messages from callbacks or
+        full LLM responses) are sent to the client as soon as they are
+        available. To enable streaming individual text chunks directly
+        from the model, set
+        [enable_text_streaming][google.cloud.ces.v1beta.SessionConfig.enable_text_streaming]
+        to true.
+
+        .. code-block:: python
+
+            # This snippet has been automatically generated and should be regarded as a
+            # code template only.
+            # It will require modifications to work:
+            # - It may require correct/in-range values for request initialization.
+            # - It may require specifying regional endpoints when creating the service
+            #   client as shown in:
+            #   https://googleapis.dev/python/google-api-core/latest/client_options.html
+            from google.cloud import ces_v1beta
+
+            async def sample_stream_run_session():
+                # Create a client
+                client = ces_v1beta.SessionServiceAsyncClient()
+
+                # Initialize request argument(s)
+                config = ces_v1beta.SessionConfig()
+                config.session = "session_value"
+
+                inputs = ces_v1beta.SessionInput()
+                inputs.text = "text_value"
+
+                request = ces_v1beta.RunSessionRequest(
+                    config=config,
+                    inputs=inputs,
+                )
+
+                # Make the request
+                stream = await client.stream_run_session(request=request)
+
+                # Handle the response
+                async for response in stream:
+                    print(response)
+
+        Args:
+            request (Optional[Union[google.cloud.ces_v1beta.types.RunSessionRequest, dict]]):
+                The request object. Request message for
+                [SessionService.RunSession][google.cloud.ces.v1beta.SessionService.RunSession].
+            retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
+                should be retried.
+            timeout (float): The timeout for this request.
+            metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
+                sent along with the request as metadata. Normally, each value must be of type `str`,
+                but for metadata keys ending with the suffix `-bin`, the corresponding values must
+                be of type `bytes`.
+
+        Returns:
+            AsyncIterable[google.cloud.ces_v1beta.types.RunSessionResponse]:
+                Response message for
+                   [SessionService.RunSession][google.cloud.ces.v1beta.SessionService.RunSession].
+
+        """
+        # Create or coerce a protobuf request object.
+        # - Use the request object if provided (there's no risk of modifying the input as
+        #   there are no flattened fields), or create one.
+        if not isinstance(request, session_service.RunSessionRequest):
+            request = session_service.RunSessionRequest(request)
+
+        # Wrap the RPC method; this adds retry and timeout information,
+        # and friendly error handling.
+        rpc = self._client._transport._wrapped_methods[
+            self._client._transport.stream_run_session
+        ]
+
+        # Certain fields should be provided within the metadata header;
+        # add these here.
+        metadata = tuple(metadata) + (
+            gapic_v1.routing_header.to_grpc_metadata(
+                (("config.session", request.config.session),)
+            ),
+        )
+
+        # Validate the universe domain.
+        self._client._validate_universe_domain()
+
+        # Send the request.
+        response = rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
+
+        # Done; return the response.
+        return response
+
     def bidi_run_session(
         self,
         requests: Optional[