diff --git a/google/cloud/aiplatform_v1/__init__.py b/google/cloud/aiplatform_v1/__init__.py
index 9c54ee4c48..79d0422665 100644
--- a/google/cloud/aiplatform_v1/__init__.py
+++ b/google/cloud/aiplatform_v1/__init__.py
@@ -563,6 +563,8 @@
 from .types.io import SharePointSources
 from .types.io import SlackSource
 from .types.io import TFRecordDestination
+from .types.io import VertexMultimodalDatasetDestination
+from .types.io import VertexMultimodalDatasetSource
 from .types.job_service import CancelBatchPredictionJobRequest
 from .types.job_service import CancelCustomJobRequest
 from .types.job_service import CancelDataLabelingJobRequest
@@ -2198,6 +2200,8 @@ def _get_version(dependency_name):
     "Value",
     "VertexAISearch",
     "VertexAiSearchConfig",
+    "VertexMultimodalDatasetDestination",
+    "VertexMultimodalDatasetSource",
     "VertexRagDataServiceClient",
     "VertexRagServiceClient",
     "VertexRagStore",
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/async_client.py b/google/cloud/aiplatform_v1/services/dataset_service/async_client.py
index f321aca6be..4df4fc103f 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/async_client.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/async_client.py
@@ -507,7 +507,6 @@ async def sample_get_dataset():
             request (Optional[Union[google.cloud.aiplatform_v1.types.GetDatasetRequest, dict]]):
                 The request object. Request message for
                 [DatasetService.GetDataset][google.cloud.aiplatform.v1.DatasetService.GetDataset].
-                Next ID: 4
             name (:class:`str`):
                 Required. The name of the Dataset
                 resource.
@@ -1704,7 +1703,6 @@ async def sample_get_dataset_version():
             request (Optional[Union[google.cloud.aiplatform_v1.types.GetDatasetVersionRequest, dict]]):
                 The request object. Request message for
                 [DatasetService.GetDatasetVersion][google.cloud.aiplatform.v1.DatasetService.GetDatasetVersion].
-                Next ID: 4
             name (:class:`str`):
                 Required. The resource name of the Dataset version to
                 delete. Format:
@@ -2643,10 +2641,7 @@ async def list_annotations(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> pagers.ListAnnotationsAsyncPager:
-        r"""Lists Annotations belongs to a dataitem
-        This RPC is only available in InternalDatasetService. It
-        is only used for exporting conversation data to CCAI
-        Insights.
+        r"""Lists Annotations belongs to a dataitem.
 
         .. code-block:: python
 
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/client.py b/google/cloud/aiplatform_v1/services/dataset_service/client.py
index 9e0e03ff4f..8af5856750 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/client.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/client.py
@@ -1091,7 +1091,6 @@ def sample_get_dataset():
             request (Union[google.cloud.aiplatform_v1.types.GetDatasetRequest, dict]):
                 The request object. Request message for
                 [DatasetService.GetDataset][google.cloud.aiplatform.v1.DatasetService.GetDataset].
-                Next ID: 4
             name (str):
                 Required. The name of the Dataset
                 resource.
@@ -2261,7 +2260,6 @@ def sample_get_dataset_version():
             request (Union[google.cloud.aiplatform_v1.types.GetDatasetVersionRequest, dict]):
                 The request object. Request message for
                 [DatasetService.GetDatasetVersion][google.cloud.aiplatform.v1.DatasetService.GetDatasetVersion].
-                Next ID: 4
             name (str):
                 Required. The resource name of the Dataset version to
                 delete. Format:
@@ -3177,10 +3175,7 @@ def list_annotations(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> pagers.ListAnnotationsPager:
-        r"""Lists Annotations belongs to a dataitem
-        This RPC is only available in InternalDatasetService. It
-        is only used for exporting conversation data to CCAI
-        Insights.
+        r"""Lists Annotations belongs to a dataitem.
 
         .. code-block:: python
 
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc.py b/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc.py
index 8410f7f790..baa6b4d9ba 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc.py
@@ -853,10 +853,7 @@ def list_annotations(
     ]:
         r"""Return a callable for the list annotations method over gRPC.
 
-        Lists Annotations belongs to a dataitem
-        This RPC is only available in InternalDatasetService. It
-        is only used for exporting conversation data to CCAI
-        Insights.
+        Lists Annotations belongs to a dataitem.
 
         Returns:
             Callable[[~.ListAnnotationsRequest],
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc_asyncio.py b/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc_asyncio.py
index 1cdabd6e2f..4ecd09f9ff 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc_asyncio.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/transports/grpc_asyncio.py
@@ -880,10 +880,7 @@ def list_annotations(
     ]:
         r"""Return a callable for the list annotations method over gRPC.
 
-        Lists Annotations belongs to a dataitem
-        This RPC is only available in InternalDatasetService. It
-        is only used for exporting conversation data to CCAI
-        Insights.
+        Lists Annotations belongs to a dataitem.
 
         Returns:
             Callable[[~.ListAnnotationsRequest],
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/transports/rest.py b/google/cloud/aiplatform_v1/services/dataset_service/transports/rest.py
index e084918200..98fb0171c2 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/transports/rest.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/transports/rest.py
@@ -4569,7 +4569,6 @@ def __call__(
                 request (~.dataset_service.GetDatasetRequest):
                     The request object. Request message for
                 [DatasetService.GetDataset][google.cloud.aiplatform.v1.DatasetService.GetDataset].
-                Next ID: 4
                 retry (google.api_core.retry.Retry): Designation of what errors, if any,
                     should be retried.
                 timeout (float): The timeout for this request.
@@ -4720,7 +4719,6 @@ def __call__(
                 request (~.dataset_service.GetDatasetVersionRequest):
                     The request object. Request message for
                 [DatasetService.GetDatasetVersion][google.cloud.aiplatform.v1.DatasetService.GetDatasetVersion].
-                Next ID: 4
                 retry (google.api_core.retry.Retry): Designation of what errors, if any,
                     should be retried.
                 timeout (float): The timeout for this request.
diff --git a/google/cloud/aiplatform_v1/services/dataset_service/transports/rest_asyncio.py b/google/cloud/aiplatform_v1/services/dataset_service/transports/rest_asyncio.py
index ddc755b15b..378a0a7ef6 100644
--- a/google/cloud/aiplatform_v1/services/dataset_service/transports/rest_asyncio.py
+++ b/google/cloud/aiplatform_v1/services/dataset_service/transports/rest_asyncio.py
@@ -2839,7 +2839,6 @@ async def __call__(
                 request (~.dataset_service.GetDatasetRequest):
                     The request object. Request message for
                 [DatasetService.GetDataset][google.cloud.aiplatform.v1.DatasetService.GetDataset].
-                Next ID: 4
                 retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
                     should be retried.
                 timeout (float): The timeout for this request.
@@ -2999,7 +2998,6 @@ async def __call__(
                 request (~.dataset_service.GetDatasetVersionRequest):
                     The request object. Request message for
                 [DatasetService.GetDatasetVersion][google.cloud.aiplatform.v1.DatasetService.GetDatasetVersion].
-                Next ID: 4
                 retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
                     should be retried.
                 timeout (float): The timeout for this request.
diff --git a/google/cloud/aiplatform_v1/services/migration_service/client.py b/google/cloud/aiplatform_v1/services/migration_service/client.py
index e626e873a0..8755475c2d 100644
--- a/google/cloud/aiplatform_v1/services/migration_service/client.py
+++ b/google/cloud/aiplatform_v1/services/migration_service/client.py
@@ -271,40 +271,40 @@ def parse_annotated_dataset_path(path: str) -> Dict[str, str]:
     @staticmethod
     def dataset_path(
         project: str,
+        location: str,
         dataset: str,
     ) -> str:
         """Returns a fully-qualified dataset string."""
-        return "projects/{project}/datasets/{dataset}".format(
+        return "projects/{project}/locations/{location}/datasets/{dataset}".format(
             project=project,
+            location=location,
             dataset=dataset,
         )
 
     @staticmethod
     def parse_dataset_path(path: str) -> Dict[str, str]:
         """Parses a dataset path into its component segments."""
-        m = re.match(r"^projects/(?P<project>.+?)/datasets/(?P<dataset>.+?)$", path)
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/datasets/(?P<dataset>.+?)$",
+            path,
+        )
         return m.groupdict() if m else {}
 
     @staticmethod
     def dataset_path(
         project: str,
-        location: str,
         dataset: str,
     ) -> str:
         """Returns a fully-qualified dataset string."""
-        return "projects/{project}/locations/{location}/datasets/{dataset}".format(
+        return "projects/{project}/datasets/{dataset}".format(
             project=project,
-            location=location,
             dataset=dataset,
         )
 
     @staticmethod
     def parse_dataset_path(path: str) -> Dict[str, str]:
         """Parses a dataset path into its component segments."""
-        m = re.match(
-            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/datasets/(?P<dataset>.+?)$",
-            path,
-        )
+        m = re.match(r"^projects/(?P<project>.+?)/datasets/(?P<dataset>.+?)$", path)
         return m.groupdict() if m else {}
 
     @staticmethod
diff --git a/google/cloud/aiplatform_v1/types/__init__.py b/google/cloud/aiplatform_v1/types/__init__.py
index 0bfadf9248..4f2c8b83bd 100644
--- a/google/cloud/aiplatform_v1/types/__init__.py
+++ b/google/cloud/aiplatform_v1/types/__init__.py
@@ -566,6 +566,8 @@
     SharePointSources,
     SlackSource,
     TFRecordDestination,
+    VertexMultimodalDatasetDestination,
+    VertexMultimodalDatasetSource,
 )
 from .job_service import (
     CancelBatchPredictionJobRequest,
@@ -1665,6 +1667,8 @@
     "SharePointSources",
     "SlackSource",
     "TFRecordDestination",
+    "VertexMultimodalDatasetDestination",
+    "VertexMultimodalDatasetSource",
     "CancelBatchPredictionJobRequest",
     "CancelCustomJobRequest",
     "CancelDataLabelingJobRequest",
diff --git a/google/cloud/aiplatform_v1/types/batch_prediction_job.py b/google/cloud/aiplatform_v1/types/batch_prediction_job.py
index e1c263e295..8a2d6ac15a 100644
--- a/google/cloud/aiplatform_v1/types/batch_prediction_job.py
+++ b/google/cloud/aiplatform_v1/types/batch_prediction_job.py
@@ -273,6 +273,11 @@ class InputConfig(proto.Message):
                 additional columns that are not described by the
                 schema, and they will be ignored.
 
+                This field is a member of `oneof`_ ``source``.
+            vertex_multimodal_dataset_source (google.cloud.aiplatform_v1.types.VertexMultimodalDatasetSource):
+                A Vertex Managed Dataset. Currently, only
+                datasets of type Multimodal are supported.
+
                 This field is a member of `oneof`_ ``source``.
             instances_format (str):
                 Required. The format in which instances are given, must be
@@ -293,6 +298,14 @@ class InputConfig(proto.Message):
             oneof="source",
             message=io.BigQuerySource,
         )
+        vertex_multimodal_dataset_source: io.VertexMultimodalDatasetSource = (
+            proto.Field(
+                proto.MESSAGE,
+                number=4,
+                oneof="source",
+                message=io.VertexMultimodalDatasetSource,
+            )
+        )
         instances_format: str = proto.Field(
             proto.STRING,
             number=1,
@@ -489,6 +502,11 @@ class OutputConfig(proto.Message):
                 [google.rpc.Status][google.rpc.Status] represented as a
                 STRUCT, and containing only ``code`` and ``message``.
 
+                This field is a member of `oneof`_ ``destination``.
+            vertex_multimodal_dataset_destination (google.cloud.aiplatform_v1.types.VertexMultimodalDatasetDestination):
+                The details for a Vertex Multimodal Dataset
+                that will be created for the output.
+
                 This field is a member of `oneof`_ ``destination``.
             predictions_format (str):
                 Required. The format in which Vertex AI gives the
@@ -509,6 +527,14 @@ class OutputConfig(proto.Message):
             oneof="destination",
             message=io.BigQueryDestination,
         )
+        vertex_multimodal_dataset_destination: io.VertexMultimodalDatasetDestination = (
+            proto.Field(
+                proto.MESSAGE,
+                number=6,
+                oneof="destination",
+                message=io.VertexMultimodalDatasetDestination,
+            )
+        )
         predictions_format: str = proto.Field(
             proto.STRING,
             number=1,
@@ -537,6 +563,13 @@ class OutputInfo(proto.Message):
                 ``bq://projectId.bqDatasetId`` format, into which the
                 prediction output is written.
 
+                This field is a member of `oneof`_ ``output_location``.
+            vertex_multimodal_dataset_name (str):
+                Output only. The resource name of the Vertex Managed Dataset
+                created, into which the prediction output is written.
+                Format:
+                ``projects/{project}/locations/{location}/datasets/{dataset}``
+
                 This field is a member of `oneof`_ ``output_location``.
             bigquery_output_table (str):
                 Output only. The name of the BigQuery table created, in
@@ -555,6 +588,11 @@ class OutputInfo(proto.Message):
             number=2,
             oneof="output_location",
         )
+        vertex_multimodal_dataset_name: str = proto.Field(
+            proto.STRING,
+            number=5,
+            oneof="output_location",
+        )
         bigquery_output_table: str = proto.Field(
             proto.STRING,
             number=4,
diff --git a/google/cloud/aiplatform_v1/types/dataset.py b/google/cloud/aiplatform_v1/types/dataset.py
index c810b9997b..55c0a49670 100644
--- a/google/cloud/aiplatform_v1/types/dataset.py
+++ b/google/cloud/aiplatform_v1/types/dataset.py
@@ -43,8 +43,9 @@ class Dataset(proto.Message):
 
     Attributes:
         name (str):
-            Output only. Identifier. The resource name of
-            the Dataset.
+            Output only. Identifier. The resource name of the Dataset.
+            Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}``
         display_name (str):
             Required. The user-defined name of the
             Dataset. The name can be up to 128 characters
diff --git a/google/cloud/aiplatform_v1/types/dataset_service.py b/google/cloud/aiplatform_v1/types/dataset_service.py
index aa594f5304..858d1ec4e6 100644
--- a/google/cloud/aiplatform_v1/types/dataset_service.py
+++ b/google/cloud/aiplatform_v1/types/dataset_service.py
@@ -112,7 +112,6 @@ class CreateDatasetOperationMetadata(proto.Message):
 class GetDatasetRequest(proto.Message):
     r"""Request message for
     [DatasetService.GetDataset][google.cloud.aiplatform.v1.DatasetService.GetDataset].
-    Next ID: 4
 
     Attributes:
         name (str):
@@ -489,7 +488,6 @@ class DeleteDatasetVersionRequest(proto.Message):
 class GetDatasetVersionRequest(proto.Message):
     r"""Request message for
     [DatasetService.GetDatasetVersion][google.cloud.aiplatform.v1.DatasetService.GetDatasetVersion].
-    Next ID: 4
 
     Attributes:
         name (str):
diff --git a/google/cloud/aiplatform_v1/types/dataset_version.py b/google/cloud/aiplatform_v1/types/dataset_version.py
index 5a03fe5aa8..22affcb419 100644
--- a/google/cloud/aiplatform_v1/types/dataset_version.py
+++ b/google/cloud/aiplatform_v1/types/dataset_version.py
@@ -36,8 +36,9 @@ class DatasetVersion(proto.Message):
 
     Attributes:
         name (str):
-            Output only. Identifier. The resource name of
-            the DatasetVersion.
+            Output only. Identifier. The resource name of the
+            DatasetVersion. Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}/datasetVersions/{dataset_version}``
         create_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. Timestamp when this
             DatasetVersion was created.
diff --git a/google/cloud/aiplatform_v1/types/io.py b/google/cloud/aiplatform_v1/types/io.py
index 07d89f0bea..ab5f96aecd 100644
--- a/google/cloud/aiplatform_v1/types/io.py
+++ b/google/cloud/aiplatform_v1/types/io.py
@@ -32,6 +32,8 @@
         "GcsDestination",
         "BigQuerySource",
         "BigQueryDestination",
+        "VertexMultimodalDatasetSource",
+        "VertexMultimodalDatasetDestination",
         "CsvDestination",
         "TFRecordDestination",
         "ContainerRegistryDestination",
@@ -152,6 +154,46 @@ class BigQueryDestination(proto.Message):
     )
 
 
+class VertexMultimodalDatasetSource(proto.Message):
+    r"""The Vertex Multimodal Dataset for the input content.
+
+    Attributes:
+        dataset_name (str):
+            Required. The resource name of the Vertex Dataset. Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}``
+    """
+
+    dataset_name: str = proto.Field(
+        proto.STRING,
+        number=1,
+    )
+
+
+class VertexMultimodalDatasetDestination(proto.Message):
+    r"""The details for a Vertex Multimodal Dataset output.
+
+    Attributes:
+        bigquery_destination (google.cloud.aiplatform_v1.types.BigQueryDestination):
+            Optional. The destination of the underlying
+            BigQuery table that will be created for the
+            output Multimodal Dataset. If not specified, the
+            BigQuery table will be created in a default
+            BigQuery dataset.
+        display_name (str):
+            Optional. Display name of the output dataset.
+    """
+
+    bigquery_destination: "BigQueryDestination" = proto.Field(
+        proto.MESSAGE,
+        number=1,
+        message="BigQueryDestination",
+    )
+    display_name: str = proto.Field(
+        proto.STRING,
+        number=2,
+    )
+
+
 class CsvDestination(proto.Message):
     r"""The storage details for CSV output content.
 
diff --git a/google/cloud/aiplatform_v1beta1/__init__.py b/google/cloud/aiplatform_v1beta1/__init__.py
index 759601dc07..cef7b426de 100644
--- a/google/cloud/aiplatform_v1beta1/__init__.py
+++ b/google/cloud/aiplatform_v1beta1/__init__.py
@@ -292,6 +292,7 @@
 from .types.evaluation_service import CometInstance
 from .types.evaluation_service import CometResult
 from .types.evaluation_service import CometSpec
+from .types.evaluation_service import ComputationBasedMetricSpec
 from .types.evaluation_service import ContentMap
 from .types.evaluation_service import CustomOutput
 from .types.evaluation_service import CustomOutputFormatConfig
@@ -318,7 +319,9 @@
 from .types.evaluation_service import GroundednessInstance
 from .types.evaluation_service import GroundednessResult
 from .types.evaluation_service import GroundednessSpec
+from .types.evaluation_service import LLMBasedMetricSpec
 from .types.evaluation_service import Metric
+from .types.evaluation_service import MetricResult
 from .types.evaluation_service import MetricxInput
 from .types.evaluation_service import MetricxInstance
 from .types.evaluation_service import MetricxResult
@@ -341,6 +344,7 @@
 from .types.evaluation_service import PointwiseMetricInstance
 from .types.evaluation_service import PointwiseMetricResult
 from .types.evaluation_service import PointwiseMetricSpec
+from .types.evaluation_service import PredefinedMetricSpec
 from .types.evaluation_service import QuestionAnsweringCorrectnessInput
 from .types.evaluation_service import QuestionAnsweringCorrectnessInstance
 from .types.evaluation_service import QuestionAnsweringCorrectnessResult
@@ -697,6 +701,8 @@
 from .types.io import SharePointSources
 from .types.io import SlackSource
 from .types.io import TFRecordDestination
+from .types.io import VertexMultimodalDatasetDestination
+from .types.io import VertexMultimodalDatasetSource
 from .types.job_service import CancelBatchPredictionJobRequest
 from .types.job_service import CancelCustomJobRequest
 from .types.job_service import CancelDataLabelingJobRequest
@@ -1560,6 +1566,7 @@ def _get_version(dependency_name):
     "CometSpec",
     "CompleteTrialRequest",
     "CompletionStats",
+    "ComputationBasedMetricSpec",
     "ComputeTokensRequest",
     "ComputeTokensResponse",
     "ContainerRegistryDestination",
@@ -2003,6 +2010,7 @@ def _get_version(dependency_name):
     "JiraSource",
     "JobServiceClient",
     "JobState",
+    "LLMBasedMetricSpec",
     "LargeModelReference",
     "LineageSubgraph",
     "ListAnnotationsRequest",
@@ -2146,6 +2154,7 @@ def _get_version(dependency_name):
     "MetadataServiceClient",
     "MetadataStore",
     "Metric",
+    "MetricResult",
     "MetricxInput",
     "MetricxInstance",
     "MetricxResult",
@@ -2262,6 +2271,7 @@ def _get_version(dependency_name):
     "PostStartupScriptConfig",
     "PreTunedModel",
     "PrebuiltVoiceConfig",
+    "PredefinedMetricSpec",
     "PredefinedSplit",
     "PredictLongRunningMetadata",
     "PredictLongRunningResponse",
@@ -2664,6 +2674,8 @@ def _get_version(dependency_name):
     "VeoTuningSpec",
     "VertexAISearch",
     "VertexAiSearchConfig",
+    "VertexMultimodalDatasetDestination",
+    "VertexMultimodalDatasetSource",
     "VertexRagDataServiceClient",
     "VertexRagServiceClient",
     "VertexRagStore",
diff --git a/google/cloud/aiplatform_v1beta1/services/dataset_service/async_client.py b/google/cloud/aiplatform_v1beta1/services/dataset_service/async_client.py
index c69e57edea..0e45ac6915 100644
--- a/google/cloud/aiplatform_v1beta1/services/dataset_service/async_client.py
+++ b/google/cloud/aiplatform_v1beta1/services/dataset_service/async_client.py
@@ -119,6 +119,8 @@ class DatasetServiceAsyncClient:
     parse_rag_corpus_path = staticmethod(DatasetServiceClient.parse_rag_corpus_path)
     saved_query_path = staticmethod(DatasetServiceClient.saved_query_path)
     parse_saved_query_path = staticmethod(DatasetServiceClient.parse_saved_query_path)
+    template_path = staticmethod(DatasetServiceClient.template_path)
+    parse_template_path = staticmethod(DatasetServiceClient.parse_template_path)
     common_billing_account_path = staticmethod(
         DatasetServiceClient.common_billing_account_path
     )
diff --git a/google/cloud/aiplatform_v1beta1/services/dataset_service/client.py b/google/cloud/aiplatform_v1beta1/services/dataset_service/client.py
index fa2c36195d..694acd755b 100644
--- a/google/cloud/aiplatform_v1beta1/services/dataset_service/client.py
+++ b/google/cloud/aiplatform_v1beta1/services/dataset_service/client.py
@@ -469,6 +469,28 @@ def parse_saved_query_path(path: str) -> Dict[str, str]:
         )
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def template_path(
+        project: str,
+        location: str,
+        template: str,
+    ) -> str:
+        """Returns a fully-qualified template string."""
+        return "projects/{project}/locations/{location}/templates/{template}".format(
+            project=project,
+            location=location,
+            template=template,
+        )
+
+    @staticmethod
+    def parse_template_path(path: str) -> Dict[str, str]:
+        """Parses a template path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/templates/(?P<template>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def common_billing_account_path(
         billing_account: str,
diff --git a/google/cloud/aiplatform_v1beta1/services/evaluation_service/async_client.py b/google/cloud/aiplatform_v1beta1/services/evaluation_service/async_client.py
index 67ba2db8fb..0235b174af 100644
--- a/google/cloud/aiplatform_v1beta1/services/evaluation_service/async_client.py
+++ b/google/cloud/aiplatform_v1beta1/services/evaluation_service/async_client.py
@@ -415,12 +415,16 @@ async def sample_evaluate_dataset():
                 dataset = aiplatform_v1beta1.EvaluationDataset()
                 dataset.gcs_source.uris = ['uris_value1', 'uris_value2']
 
+                metrics = aiplatform_v1beta1.Metric()
+                metrics.predefined_metric_spec.metric_spec_name = "metric_spec_name_value"
+
                 output_config = aiplatform_v1beta1.OutputConfig()
                 output_config.gcs_destination.output_uri_prefix = "output_uri_prefix_value"
 
                 request = aiplatform_v1beta1.EvaluateDatasetRequest(
                     location="location_value",
                     dataset=dataset,
+                    metrics=metrics,
                     output_config=output_config,
                 )
 
@@ -452,7 +456,8 @@ async def sample_evaluate_dataset():
 
                 The result type for the operation will be
                 :class:`google.cloud.aiplatform_v1beta1.types.EvaluateDatasetResponse`
-                Response in LRO for EvaluationService.EvaluateDataset.
+                The results from an evaluation run performed by the
+                EvaluationService.
 
         """
         # Create or coerce a protobuf request object.
diff --git a/google/cloud/aiplatform_v1beta1/services/evaluation_service/client.py b/google/cloud/aiplatform_v1beta1/services/evaluation_service/client.py
index 7d5596e66d..c181fb4966 100644
--- a/google/cloud/aiplatform_v1beta1/services/evaluation_service/client.py
+++ b/google/cloud/aiplatform_v1beta1/services/evaluation_service/client.py
@@ -873,12 +873,16 @@ def sample_evaluate_dataset():
                 dataset = aiplatform_v1beta1.EvaluationDataset()
                 dataset.gcs_source.uris = ['uris_value1', 'uris_value2']
 
+                metrics = aiplatform_v1beta1.Metric()
+                metrics.predefined_metric_spec.metric_spec_name = "metric_spec_name_value"
+
                 output_config = aiplatform_v1beta1.OutputConfig()
                 output_config.gcs_destination.output_uri_prefix = "output_uri_prefix_value"
 
                 request = aiplatform_v1beta1.EvaluateDatasetRequest(
                     location="location_value",
                     dataset=dataset,
+                    metrics=metrics,
                     output_config=output_config,
                 )
 
@@ -910,7 +914,8 @@ def sample_evaluate_dataset():
 
                 The result type for the operation will be
                 :class:`google.cloud.aiplatform_v1beta1.types.EvaluateDatasetResponse`
-                Response in LRO for EvaluationService.EvaluateDataset.
+                The results from an evaluation run performed by the
+                EvaluationService.
 
         """
         # Create or coerce a protobuf request object.
diff --git a/google/cloud/aiplatform_v1beta1/services/evaluation_service/transports/rest_base.py b/google/cloud/aiplatform_v1beta1/services/evaluation_service/transports/rest_base.py
index 908821c195..7dab524673 100644
--- a/google/cloud/aiplatform_v1beta1/services/evaluation_service/transports/rest_base.py
+++ b/google/cloud/aiplatform_v1beta1/services/evaluation_service/transports/rest_base.py
@@ -115,6 +115,11 @@ def _get_http_options():
                     "uri": "/v1beta1/{location=projects/*/locations/*}:evaluateDataset",
                     "body": "*",
                 },
+                {
+                    "method": "post",
+                    "uri": "/v1beta1:evaluateDataset",
+                    "body": "*",
+                },
             ]
             return http_options
 
@@ -172,6 +177,11 @@ def _get_http_options():
                     "uri": "/v1beta1/{location=projects/*/locations/*}:evaluateInstances",
                     "body": "*",
                 },
+                {
+                    "method": "post",
+                    "uri": "/v1beta1:evaluateInstances",
+                    "body": "*",
+                },
             ]
             return http_options
 
diff --git a/google/cloud/aiplatform_v1beta1/types/__init__.py b/google/cloud/aiplatform_v1beta1/types/__init__.py
index 299cc957ec..40d2829b6a 100644
--- a/google/cloud/aiplatform_v1beta1/types/__init__.py
+++ b/google/cloud/aiplatform_v1beta1/types/__init__.py
@@ -235,6 +235,7 @@
     CometInstance,
     CometResult,
     CometSpec,
+    ComputationBasedMetricSpec,
     ContentMap,
     CustomOutput,
     CustomOutputFormatConfig,
@@ -261,7 +262,9 @@
     GroundednessInstance,
     GroundednessResult,
     GroundednessSpec,
+    LLMBasedMetricSpec,
     Metric,
+    MetricResult,
     MetricxInput,
     MetricxInstance,
     MetricxResult,
@@ -284,6 +287,7 @@
     PointwiseMetricInstance,
     PointwiseMetricResult,
     PointwiseMetricSpec,
+    PredefinedMetricSpec,
     QuestionAnsweringCorrectnessInput,
     QuestionAnsweringCorrectnessInstance,
     QuestionAnsweringCorrectnessResult,
@@ -704,6 +708,8 @@
     SharePointSources,
     SlackSource,
     TFRecordDestination,
+    VertexMultimodalDatasetDestination,
+    VertexMultimodalDatasetSource,
 )
 from .job_service import (
     CancelBatchPredictionJobRequest,
@@ -1647,6 +1653,7 @@
     "CometInstance",
     "CometResult",
     "CometSpec",
+    "ComputationBasedMetricSpec",
     "ContentMap",
     "CustomOutput",
     "CustomOutputFormatConfig",
@@ -1673,7 +1680,9 @@
     "GroundednessInstance",
     "GroundednessResult",
     "GroundednessSpec",
+    "LLMBasedMetricSpec",
     "Metric",
+    "MetricResult",
     "MetricxInput",
     "MetricxInstance",
     "MetricxResult",
@@ -1696,6 +1705,7 @@
     "PointwiseMetricInstance",
     "PointwiseMetricResult",
     "PointwiseMetricSpec",
+    "PredefinedMetricSpec",
     "QuestionAnsweringCorrectnessInput",
     "QuestionAnsweringCorrectnessInstance",
     "QuestionAnsweringCorrectnessResult",
@@ -2048,6 +2058,8 @@
     "SharePointSources",
     "SlackSource",
     "TFRecordDestination",
+    "VertexMultimodalDatasetDestination",
+    "VertexMultimodalDatasetSource",
     "CancelBatchPredictionJobRequest",
     "CancelCustomJobRequest",
     "CancelDataLabelingJobRequest",
diff --git a/google/cloud/aiplatform_v1beta1/types/batch_prediction_job.py b/google/cloud/aiplatform_v1beta1/types/batch_prediction_job.py
index d7b16541c6..f67df622a3 100644
--- a/google/cloud/aiplatform_v1beta1/types/batch_prediction_job.py
+++ b/google/cloud/aiplatform_v1beta1/types/batch_prediction_job.py
@@ -289,6 +289,11 @@ class InputConfig(proto.Message):
                 additional columns that are not described by the
                 schema, and they will be ignored.
 
+                This field is a member of `oneof`_ ``source``.
+            vertex_multimodal_dataset_source (google.cloud.aiplatform_v1beta1.types.VertexMultimodalDatasetSource):
+                A Vertex Managed Dataset. Currently, only
+                datasets of type Multimodal are supported.
+
                 This field is a member of `oneof`_ ``source``.
             instances_format (str):
                 Required. The format in which instances are given, must be
@@ -309,6 +314,14 @@ class InputConfig(proto.Message):
             oneof="source",
             message=io.BigQuerySource,
         )
+        vertex_multimodal_dataset_source: io.VertexMultimodalDatasetSource = (
+            proto.Field(
+                proto.MESSAGE,
+                number=4,
+                oneof="source",
+                message=io.VertexMultimodalDatasetSource,
+            )
+        )
         instances_format: str = proto.Field(
             proto.STRING,
             number=1,
@@ -505,6 +518,11 @@ class OutputConfig(proto.Message):
                 [google.rpc.Status][google.rpc.Status] represented as a
                 STRUCT, and containing only ``code`` and ``message``.
 
+                This field is a member of `oneof`_ ``destination``.
+            vertex_multimodal_dataset_destination (google.cloud.aiplatform_v1beta1.types.VertexMultimodalDatasetDestination):
+                The details for a Vertex Multimodal Dataset
+                that will be created for the output.
+
                 This field is a member of `oneof`_ ``destination``.
             predictions_format (str):
                 Required. The format in which Vertex AI gives the
@@ -525,6 +543,14 @@ class OutputConfig(proto.Message):
             oneof="destination",
             message=io.BigQueryDestination,
         )
+        vertex_multimodal_dataset_destination: io.VertexMultimodalDatasetDestination = (
+            proto.Field(
+                proto.MESSAGE,
+                number=6,
+                oneof="destination",
+                message=io.VertexMultimodalDatasetDestination,
+            )
+        )
         predictions_format: str = proto.Field(
             proto.STRING,
             number=1,
@@ -553,6 +579,13 @@ class OutputInfo(proto.Message):
                 ``bq://projectId.bqDatasetId`` format, into which the
                 prediction output is written.
 
+                This field is a member of `oneof`_ ``output_location``.
+            vertex_multimodal_dataset_name (str):
+                Output only. The resource name of the Vertex Managed Dataset
+                created, into which the prediction output is written.
+                Format:
+                ``projects/{project}/locations/{location}/datasets/{dataset}``
+
                 This field is a member of `oneof`_ ``output_location``.
             bigquery_output_table (str):
                 Output only. The name of the BigQuery table created, in
@@ -571,6 +604,11 @@ class OutputInfo(proto.Message):
             number=2,
             oneof="output_location",
         )
+        vertex_multimodal_dataset_name: str = proto.Field(
+            proto.STRING,
+            number=5,
+            oneof="output_location",
+        )
         bigquery_output_table: str = proto.Field(
             proto.STRING,
             number=4,
diff --git a/google/cloud/aiplatform_v1beta1/types/dataset.py b/google/cloud/aiplatform_v1beta1/types/dataset.py
index 0abfb5459b..b1bf1242b8 100644
--- a/google/cloud/aiplatform_v1beta1/types/dataset.py
+++ b/google/cloud/aiplatform_v1beta1/types/dataset.py
@@ -42,8 +42,9 @@ class Dataset(proto.Message):
 
     Attributes:
         name (str):
-            Output only. Identifier. The resource name of
-            the Dataset.
+            Output only. Identifier. The resource name of the Dataset.
+            Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}``
         display_name (str):
             Required. The user-defined name of the
             Dataset. The name can be up to 128 characters
diff --git a/google/cloud/aiplatform_v1beta1/types/dataset_service.py b/google/cloud/aiplatform_v1beta1/types/dataset_service.py
index 1289459102..739728b4d6 100644
--- a/google/cloud/aiplatform_v1beta1/types/dataset_service.py
+++ b/google/cloud/aiplatform_v1beta1/types/dataset_service.py
@@ -1562,6 +1562,10 @@ class GeminiExample(proto.Message):
             Optional. Per request settings for blocking
             unsafe content. Enforced on
             GenerateContentResponse.candidates.
+        model_armor_config (google.cloud.aiplatform_v1beta1.types.ModelArmorConfig):
+            Optional. Settings for prompt and response sanitization
+            using the Model Armor service. If supplied, safety_settings
+            must not be supplied.
         generation_config (google.cloud.aiplatform_v1beta1.types.GenerationConfig):
             Optional. Generation config.
     """
@@ -1605,6 +1609,11 @@ class GeminiExample(proto.Message):
         number=3,
         message=content.SafetySetting,
     )
+    model_armor_config: content.ModelArmorConfig = proto.Field(
+        proto.MESSAGE,
+        number=11,
+        message=content.ModelArmorConfig,
+    )
     generation_config: content.GenerationConfig = proto.Field(
         proto.MESSAGE,
         number=4,
diff --git a/google/cloud/aiplatform_v1beta1/types/dataset_version.py b/google/cloud/aiplatform_v1beta1/types/dataset_version.py
index 4a587ac1c6..88cde27d86 100644
--- a/google/cloud/aiplatform_v1beta1/types/dataset_version.py
+++ b/google/cloud/aiplatform_v1beta1/types/dataset_version.py
@@ -36,8 +36,9 @@ class DatasetVersion(proto.Message):
 
     Attributes:
         name (str):
-            Output only. Identifier. The resource name of
-            the DatasetVersion.
+            Output only. Identifier. The resource name of the
+            DatasetVersion. Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}/datasetVersions/{dataset_version}``
         create_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. Timestamp when this
             DatasetVersion was created.
diff --git a/google/cloud/aiplatform_v1beta1/types/evaluation_service.py b/google/cloud/aiplatform_v1beta1/types/evaluation_service.py
index 6f7cf4f960..5d0dbb2645 100644
--- a/google/cloud/aiplatform_v1beta1/types/evaluation_service.py
+++ b/google/cloud/aiplatform_v1beta1/types/evaluation_service.py
@@ -22,6 +22,8 @@
 from google.cloud.aiplatform_v1beta1.types import content
 from google.cloud.aiplatform_v1beta1.types import io
 from google.cloud.aiplatform_v1beta1.types import operation
+from google.protobuf import struct_pb2  # type: ignore
+from google.rpc import status_pb2  # type: ignore
 
 
 __protobuf__ = proto.module(
@@ -40,6 +42,10 @@
         "AutoraterConfig",
         "EvaluateInstancesRequest",
         "EvaluateInstancesResponse",
+        "MetricResult",
+        "PredefinedMetricSpec",
+        "ComputationBasedMetricSpec",
+        "LLMBasedMetricSpec",
         "ExactMatchInput",
         "ExactMatchInstance",
         "ExactMatchSpec",
@@ -228,16 +234,16 @@ class EvaluateDatasetOperationMetadata(proto.Message):
 
 
 class EvaluateDatasetResponse(proto.Message):
-    r"""Response in LRO for EvaluationService.EvaluateDataset.
+    r"""The results from an evaluation run performed by the
+    EvaluationService.
 
     Attributes:
         aggregation_output (google.cloud.aiplatform_v1beta1.types.AggregationOutput):
             Output only. Aggregation statistics derived
-            from results of
-            EvaluationService.EvaluateDataset.
+            from results of EvaluationService.
         output_info (google.cloud.aiplatform_v1beta1.types.OutputInfo):
             Output only. Output info for
-            EvaluationService.EvaluateDataset.
+            EvaluationService.
     """
 
     aggregation_output: "AggregationOutput" = proto.Field(
@@ -253,9 +259,7 @@ class EvaluateDatasetResponse(proto.Message):
 
 
 class OutputInfo(proto.Message):
-    r"""Describes the info for output of
-    EvaluationService.EvaluateDataset.
-
+    r"""Describes the info for output of EvaluationService.
 
     .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
 
@@ -439,7 +443,7 @@ class OutputConfig(proto.Message):
 
 
 class Metric(proto.Message):
-    r"""The metric used for dataset level evaluation.
+    r"""The metric used for running evaluations.
 
     This message has `oneof`_ fields (mutually exclusive fields).
     For each oneof, at most one member field can be set at the same time.
@@ -449,6 +453,18 @@ class Metric(proto.Message):
     .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
 
     Attributes:
+        predefined_metric_spec (google.cloud.aiplatform_v1beta1.types.PredefinedMetricSpec):
+            The spec for a pre-defined metric.
+
+            This field is a member of `oneof`_ ``metric_spec``.
+        computation_based_metric_spec (google.cloud.aiplatform_v1beta1.types.ComputationBasedMetricSpec):
+            Spec for a computation based metric.
+
+            This field is a member of `oneof`_ ``metric_spec``.
+        llm_based_metric_spec (google.cloud.aiplatform_v1beta1.types.LLMBasedMetricSpec):
+            Spec for an LLM based metric.
+
+            This field is a member of `oneof`_ ``metric_spec``.
         pointwise_metric_spec (google.cloud.aiplatform_v1beta1.types.PointwiseMetricSpec):
             Spec for pointwise metric.
 
@@ -474,8 +490,8 @@ class Metric(proto.Message):
     """
 
     class AggregationMetric(proto.Enum):
-        r"""The aggregation metrics supported by
-        EvaluationService.EvaluateDataset.
+        r"""The per-metric statistics on evaluation results supported by
+        ``EvaluationService.EvaluateDataset``.
 
         Values:
             AGGREGATION_METRIC_UNSPECIFIED (0):
@@ -523,6 +539,24 @@ class AggregationMetric(proto.Enum):
         PERCENTILE_P95 = 9
         PERCENTILE_P99 = 10
 
+    predefined_metric_spec: "PredefinedMetricSpec" = proto.Field(
+        proto.MESSAGE,
+        number=8,
+        oneof="metric_spec",
+        message="PredefinedMetricSpec",
+    )
+    computation_based_metric_spec: "ComputationBasedMetricSpec" = proto.Field(
+        proto.MESSAGE,
+        number=9,
+        oneof="metric_spec",
+        message="ComputationBasedMetricSpec",
+    )
+    llm_based_metric_spec: "LLMBasedMetricSpec" = proto.Field(
+        proto.MESSAGE,
+        number=10,
+        oneof="metric_spec",
+        message="LLMBasedMetricSpec",
+    )
     pointwise_metric_spec: "PointwiseMetricSpec" = proto.Field(
         proto.MESSAGE,
         number=2,
@@ -1177,6 +1211,11 @@ class EvaluateInstancesResponse(proto.Message):
             metric.
 
             This field is a member of `oneof`_ ``evaluation_results``.
+        metric_results (MutableSequence[google.cloud.aiplatform_v1beta1.types.MetricResult]):
+            Metric results for each instance.
+            The order of the metric results is guaranteed to
+            be the same as the order of the instances in the
+            request.
     """
 
     exact_match_results: "ExactMatchResults" = proto.Field(
@@ -1383,6 +1422,206 @@ class EvaluateInstancesResponse(proto.Message):
         oneof="evaluation_results",
         message="RubricBasedInstructionFollowingResult",
     )
+    metric_results: MutableSequence["MetricResult"] = proto.RepeatedField(
+        proto.MESSAGE,
+        number=43,
+        message="MetricResult",
+    )
+
+
+class MetricResult(proto.Message):
+    r"""Result for a single metric on a single instance.
+
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
+    Attributes:
+        score (float):
+            Output only. The score for the metric.
+            Please refer to each metric's documentation for
+            the meaning of the score.
+
+            This field is a member of `oneof`_ ``_score``.
+        explanation (str):
+            Output only. The explanation for the metric
+            result.
+
+            This field is a member of `oneof`_ ``_explanation``.
+        error (google.rpc.status_pb2.Status):
+            Output only. The error status for the metric
+            result.
+
+            This field is a member of `oneof`_ ``_error``.
+    """
+
+    score: float = proto.Field(
+        proto.FLOAT,
+        number=1,
+        optional=True,
+    )
+    explanation: str = proto.Field(
+        proto.STRING,
+        number=3,
+        optional=True,
+    )
+    error: status_pb2.Status = proto.Field(
+        proto.MESSAGE,
+        number=4,
+        optional=True,
+        message=status_pb2.Status,
+    )
+
+
+class PredefinedMetricSpec(proto.Message):
+    r"""The spec for a pre-defined metric.
+
+    Attributes:
+        metric_spec_name (str):
+            Required. The name of a pre-defined metric, such as
+            "instruction_following_v1" or "text_quality_v1".
+        metric_spec_parameters (google.protobuf.struct_pb2.Struct):
+            Optional. The parameters needed to run the
+            pre-defined metric.
+    """
+
+    metric_spec_name: str = proto.Field(
+        proto.STRING,
+        number=1,
+    )
+    metric_spec_parameters: struct_pb2.Struct = proto.Field(
+        proto.MESSAGE,
+        number=2,
+        message=struct_pb2.Struct,
+    )
+
+
+class ComputationBasedMetricSpec(proto.Message):
+    r"""Specification for a computation based metric.
+
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
+    Attributes:
+        type_ (google.cloud.aiplatform_v1beta1.types.ComputationBasedMetricSpec.ComputationBasedMetricType):
+            Required. The type of the computation based
+            metric.
+
+            This field is a member of `oneof`_ ``_type``.
+        parameters (google.protobuf.struct_pb2.Struct):
+            Optional. A map of parameters for the metric, e.g.
+            {"rouge_type": "rougeL"}.
+
+            This field is a member of `oneof`_ ``_parameters``.
+    """
+
+    class ComputationBasedMetricType(proto.Enum):
+        r"""Types of computation based metrics.
+
+        Values:
+            COMPUTATION_BASED_METRIC_TYPE_UNSPECIFIED (0):
+                Unspecified computation based metric type.
+            EXACT_MATCH (1):
+                Exact match metric.
+            BLEU (2):
+                BLEU metric.
+            ROUGE (3):
+                ROUGE metric.
+        """
+
+        COMPUTATION_BASED_METRIC_TYPE_UNSPECIFIED = 0
+        EXACT_MATCH = 1
+        BLEU = 2
+        ROUGE = 3
+
+    type_: ComputationBasedMetricType = proto.Field(
+        proto.ENUM,
+        number=1,
+        optional=True,
+        enum=ComputationBasedMetricType,
+    )
+    parameters: struct_pb2.Struct = proto.Field(
+        proto.MESSAGE,
+        number=2,
+        optional=True,
+        message=struct_pb2.Struct,
+    )
+
+
+class LLMBasedMetricSpec(proto.Message):
+    r"""Specification for an LLM based metric.
+
+    This message has `oneof`_ fields (mutually exclusive fields).
+    For each oneof, at most one member field can be set at the same time.
+    Setting any member of the oneof automatically clears all other
+    members.
+
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
+    Attributes:
+        rubric_group_key (str):
+            Use a pre-defined group of rubrics associated with the
+            input. Refers to a key in the rubric_groups map of
+            EvaluationInstance.
+
+            This field is a member of `oneof`_ ``rubrics_source``.
+        predefined_rubric_generation_spec (google.cloud.aiplatform_v1beta1.types.PredefinedMetricSpec):
+            Dynamically generate rubrics using a
+            predefined spec.
+
+            This field is a member of `oneof`_ ``rubrics_source``.
+        metric_prompt_template (str):
+            Required. Template for the prompt sent to the
+            judge model.
+
+            This field is a member of `oneof`_ ``_metric_prompt_template``.
+        system_instruction (str):
+            Optional. System instructions for the judge
+            model.
+
+            This field is a member of `oneof`_ ``_system_instruction``.
+        judge_autorater_config (google.cloud.aiplatform_v1beta1.types.AutoraterConfig):
+            Optional. Optional configuration for the
+            judge LLM (Autorater).
+
+            This field is a member of `oneof`_ ``_judge_autorater_config``.
+        additional_config (google.protobuf.struct_pb2.Struct):
+            Optional. Optional additional configuration
+            for the metric.
+
+            This field is a member of `oneof`_ ``_additional_config``.
+    """
+
+    rubric_group_key: str = proto.Field(
+        proto.STRING,
+        number=4,
+        oneof="rubrics_source",
+    )
+    predefined_rubric_generation_spec: "PredefinedMetricSpec" = proto.Field(
+        proto.MESSAGE,
+        number=6,
+        oneof="rubrics_source",
+        message="PredefinedMetricSpec",
+    )
+    metric_prompt_template: str = proto.Field(
+        proto.STRING,
+        number=1,
+        optional=True,
+    )
+    system_instruction: str = proto.Field(
+        proto.STRING,
+        number=2,
+        optional=True,
+    )
+    judge_autorater_config: "AutoraterConfig" = proto.Field(
+        proto.MESSAGE,
+        number=3,
+        optional=True,
+        message="AutoraterConfig",
+    )
+    additional_config: struct_pb2.Struct = proto.Field(
+        proto.MESSAGE,
+        number=7,
+        optional=True,
+        message=struct_pb2.Struct,
+    )
 
 
 class ExactMatchInput(proto.Message):
diff --git a/google/cloud/aiplatform_v1beta1/types/io.py b/google/cloud/aiplatform_v1beta1/types/io.py
index c885e6b202..8cc00c6e62 100644
--- a/google/cloud/aiplatform_v1beta1/types/io.py
+++ b/google/cloud/aiplatform_v1beta1/types/io.py
@@ -32,6 +32,8 @@
         "GcsDestination",
         "BigQuerySource",
         "BigQueryDestination",
+        "VertexMultimodalDatasetSource",
+        "VertexMultimodalDatasetDestination",
         "CsvDestination",
         "TFRecordDestination",
         "ContainerRegistryDestination",
@@ -152,6 +154,46 @@ class BigQueryDestination(proto.Message):
     )
 
 
+class VertexMultimodalDatasetSource(proto.Message):
+    r"""The Vertex Multimodal Dataset for the input content.
+
+    Attributes:
+        dataset_name (str):
+            Required. The resource name of the Vertex Dataset. Format:
+            ``projects/{project}/locations/{location}/datasets/{dataset}``
+    """
+
+    dataset_name: str = proto.Field(
+        proto.STRING,
+        number=1,
+    )
+
+
+class VertexMultimodalDatasetDestination(proto.Message):
+    r"""The details for a Vertex Multimodal Dataset output.
+
+    Attributes:
+        bigquery_destination (google.cloud.aiplatform_v1beta1.types.BigQueryDestination):
+            Optional. The destination of the underlying
+            BigQuery table that will be created for the
+            output Multimodal Dataset. If not specified, the
+            BigQuery table will be created in a default
+            BigQuery dataset.
+        display_name (str):
+            Optional. Display name of the output dataset.
+    """
+
+    bigquery_destination: "BigQueryDestination" = proto.Field(
+        proto.MESSAGE,
+        number=1,
+        message="BigQueryDestination",
+    )
+    display_name: str = proto.Field(
+        proto.STRING,
+        number=2,
+    )
+
+
 class CsvDestination(proto.Message):
     r"""The storage details for CSV output content.
 
diff --git a/google/cloud/aiplatform_v1beta1/types/schedule.py b/google/cloud/aiplatform_v1beta1/types/schedule.py
index 1f8c2a41cc..1cde82a4de 100644
--- a/google/cloud/aiplatform_v1beta1/types/schedule.py
+++ b/google/cloud/aiplatform_v1beta1/types/schedule.py
@@ -125,6 +125,14 @@ class Schedule(proto.Message):
             the limit for starting the scheduled requests
             and not the execution of the operations/jobs
             created by the requests (if applicable).
+        max_concurrent_active_run_count (int):
+            Optional. Specifies the maximum number of
+            active runs that can be executed concurrently
+            for this Schedule. This limits the number of
+            runs that can be in a non-terminal state at the
+            same time.
+            Currently, this field is only supported for
+            requests of type CreatePipelineJobRequest.
         allow_queueing (bool):
             Optional. Whether new scheduled runs can be queued when
             max_concurrent_runs limit is reached. If set to true, new
@@ -279,6 +287,10 @@ class RunResponse(proto.Message):
         proto.INT64,
         number=11,
     )
+    max_concurrent_active_run_count: int = proto.Field(
+        proto.INT64,
+        number=21,
+    )
     allow_queueing: bool = proto.Field(
         proto.BOOL,
         number=12,
diff --git a/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_async.py b/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_async.py
index 8906bdaad3..16c0cd8ebf 100644
--- a/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_async.py
+++ b/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_async.py
@@ -42,12 +42,16 @@ async def sample_evaluate_dataset():
     dataset = aiplatform_v1beta1.EvaluationDataset()
     dataset.gcs_source.uris = ['uris_value1', 'uris_value2']
 
+    metrics = aiplatform_v1beta1.Metric()
+    metrics.predefined_metric_spec.metric_spec_name = "metric_spec_name_value"
+
     output_config = aiplatform_v1beta1.OutputConfig()
     output_config.gcs_destination.output_uri_prefix = "output_uri_prefix_value"
 
     request = aiplatform_v1beta1.EvaluateDatasetRequest(
         location="location_value",
         dataset=dataset,
+        metrics=metrics,
         output_config=output_config,
     )
 
diff --git a/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_sync.py b/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_sync.py
index 0fbacea68e..202e61b5f1 100644
--- a/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_sync.py
+++ b/samples/generated_samples/aiplatform_v1beta1_generated_evaluation_service_evaluate_dataset_sync.py
@@ -42,12 +42,16 @@ def sample_evaluate_dataset():
     dataset = aiplatform_v1beta1.EvaluationDataset()
     dataset.gcs_source.uris = ['uris_value1', 'uris_value2']
 
+    metrics = aiplatform_v1beta1.Metric()
+    metrics.predefined_metric_spec.metric_spec_name = "metric_spec_name_value"
+
     output_config = aiplatform_v1beta1.OutputConfig()
     output_config.gcs_destination.output_uri_prefix = "output_uri_prefix_value"
 
     request = aiplatform_v1beta1.EvaluateDatasetRequest(
         location="location_value",
         dataset=dataset,
+        metrics=metrics,
         output_config=output_config,
     )
 
diff --git a/samples/generated_samples/snippet_metadata_google.cloud.aiplatform.v1beta1.json b/samples/generated_samples/snippet_metadata_google.cloud.aiplatform.v1beta1.json
index 2a9e00ef91..e48e0302b5 100644
--- a/samples/generated_samples/snippet_metadata_google.cloud.aiplatform.v1beta1.json
+++ b/samples/generated_samples/snippet_metadata_google.cloud.aiplatform.v1beta1.json
@@ -6302,12 +6302,12 @@
       "regionTag": "aiplatform_v1beta1_generated_EvaluationService_EvaluateDataset_async",
       "segments": [
         {
-          "end": 63,
+          "end": 67,
           "start": 27,
           "type": "FULL"
         },
         {
-          "end": 63,
+          "end": 67,
           "start": 27,
           "type": "SHORT"
         },
@@ -6317,18 +6317,18 @@
           "type": "CLIENT_INITIALIZATION"
         },
         {
-          "end": 53,
+          "end": 57,
           "start": 41,
           "type": "REQUEST_INITIALIZATION"
         },
         {
-          "end": 60,
-          "start": 54,
+          "end": 64,
+          "start": 58,
           "type": "REQUEST_EXECUTION"
         },
         {
-          "end": 64,
-          "start": 61,
+          "end": 68,
+          "start": 65,
           "type": "RESPONSE_HANDLING"
         }
       ],
@@ -6378,12 +6378,12 @@
       "regionTag": "aiplatform_v1beta1_generated_EvaluationService_EvaluateDataset_sync",
       "segments": [
         {
-          "end": 63,
+          "end": 67,
           "start": 27,
           "type": "FULL"
         },
         {
-          "end": 63,
+          "end": 67,
           "start": 27,
           "type": "SHORT"
         },
@@ -6393,18 +6393,18 @@
           "type": "CLIENT_INITIALIZATION"
         },
         {
-          "end": 53,
+          "end": 57,
           "start": 41,
           "type": "REQUEST_INITIALIZATION"
         },
         {
-          "end": 60,
-          "start": 54,
+          "end": 64,
+          "start": 58,
           "type": "REQUEST_EXECUTION"
         },
         {
-          "end": 64,
-          "start": 61,
+          "end": 68,
+          "start": 65,
           "type": "RESPONSE_HANDLING"
         }
       ],
diff --git a/tests/unit/gapic/aiplatform_v1/test_job_service.py b/tests/unit/gapic/aiplatform_v1/test_job_service.py
index 25c241ef4d..b9a58d873e 100644
--- a/tests/unit/gapic/aiplatform_v1/test_job_service.py
+++ b/tests/unit/gapic/aiplatform_v1/test_job_service.py
@@ -28279,6 +28279,7 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "input_config": {
             "gcs_source": {"uris": ["uris_value1", "uris_value2"]},
             "bigquery_source": {"input_uri": "input_uri_value"},
+            "vertex_multimodal_dataset_source": {"dataset_name": "dataset_name_value"},
             "instances_format": "instances_format_value",
         },
         "instance_config": {
@@ -28298,6 +28299,10 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "output_config": {
             "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"},
             "bigquery_destination": {"output_uri": "output_uri_value"},
+            "vertex_multimodal_dataset_destination": {
+                "bigquery_destination": {},
+                "display_name": "display_name_value",
+            },
             "predictions_format": "predictions_format_value",
         },
         "dedicated_resources": {
@@ -28357,6 +28362,7 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "output_info": {
             "gcs_output_directory": "gcs_output_directory_value",
             "bigquery_output_dataset": "bigquery_output_dataset_value",
+            "vertex_multimodal_dataset_name": "vertex_multimodal_dataset_name_value",
             "bigquery_output_table": "bigquery_output_table_value",
         },
         "state": 1,
@@ -36125,6 +36131,7 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "input_config": {
             "gcs_source": {"uris": ["uris_value1", "uris_value2"]},
             "bigquery_source": {"input_uri": "input_uri_value"},
+            "vertex_multimodal_dataset_source": {"dataset_name": "dataset_name_value"},
             "instances_format": "instances_format_value",
         },
         "instance_config": {
@@ -36144,6 +36151,10 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "output_config": {
             "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"},
             "bigquery_destination": {"output_uri": "output_uri_value"},
+            "vertex_multimodal_dataset_destination": {
+                "bigquery_destination": {},
+                "display_name": "display_name_value",
+            },
             "predictions_format": "predictions_format_value",
         },
         "dedicated_resources": {
@@ -36203,6 +36214,7 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "output_info": {
             "gcs_output_directory": "gcs_output_directory_value",
             "bigquery_output_dataset": "bigquery_output_dataset_value",
+            "vertex_multimodal_dataset_name": "vertex_multimodal_dataset_name_value",
             "bigquery_output_table": "bigquery_output_table_value",
         },
         "state": 1,
diff --git a/tests/unit/gapic/aiplatform_v1/test_migration_service.py b/tests/unit/gapic/aiplatform_v1/test_migration_service.py
index aefcb219d7..a783bb76ea 100644
--- a/tests/unit/gapic/aiplatform_v1/test_migration_service.py
+++ b/tests/unit/gapic/aiplatform_v1/test_migration_service.py
@@ -5596,19 +5596,22 @@ def test_parse_annotated_dataset_path():
 
 def test_dataset_path():
     project = "cuttlefish"
-    dataset = "mussel"
-    expected = "projects/{project}/datasets/{dataset}".format(
+    location = "mussel"
+    dataset = "winkle"
+    expected = "projects/{project}/locations/{location}/datasets/{dataset}".format(
         project=project,
+        location=location,
         dataset=dataset,
     )
-    actual = MigrationServiceClient.dataset_path(project, dataset)
+    actual = MigrationServiceClient.dataset_path(project, location, dataset)
     assert expected == actual
 
 
 def test_parse_dataset_path():
     expected = {
-        "project": "winkle",
-        "dataset": "nautilus",
+        "project": "nautilus",
+        "location": "scallop",
+        "dataset": "abalone",
     }
     path = MigrationServiceClient.dataset_path(**expected)
 
@@ -5618,22 +5621,19 @@ def test_parse_dataset_path():
 
 
 def test_dataset_path():
-    project = "scallop"
-    location = "abalone"
-    dataset = "squid"
-    expected = "projects/{project}/locations/{location}/datasets/{dataset}".format(
+    project = "squid"
+    dataset = "clam"
+    expected = "projects/{project}/datasets/{dataset}".format(
         project=project,
-        location=location,
         dataset=dataset,
     )
-    actual = MigrationServiceClient.dataset_path(project, location, dataset)
+    actual = MigrationServiceClient.dataset_path(project, dataset)
     assert expected == actual
 
 
 def test_parse_dataset_path():
     expected = {
-        "project": "clam",
-        "location": "whelk",
+        "project": "whelk",
         "dataset": "octopus",
     }
     path = MigrationServiceClient.dataset_path(**expected)
diff --git a/tests/unit/gapic/aiplatform_v1beta1/test_dataset_service.py b/tests/unit/gapic/aiplatform_v1beta1/test_dataset_service.py
index f07a6ed23c..9e308e9f45 100644
--- a/tests/unit/gapic/aiplatform_v1beta1/test_dataset_service.py
+++ b/tests/unit/gapic/aiplatform_v1beta1/test_dataset_service.py
@@ -24913,8 +24913,34 @@ def test_parse_saved_query_path():
     assert expected == actual
 
 
+def test_template_path():
+    project = "cuttlefish"
+    location = "mussel"
+    template = "winkle"
+    expected = "projects/{project}/locations/{location}/templates/{template}".format(
+        project=project,
+        location=location,
+        template=template,
+    )
+    actual = DatasetServiceClient.template_path(project, location, template)
+    assert expected == actual
+
+
+def test_parse_template_path():
+    expected = {
+        "project": "nautilus",
+        "location": "scallop",
+        "template": "abalone",
+    }
+    path = DatasetServiceClient.template_path(**expected)
+
+    # Check that the path construction is reversible.
+    actual = DatasetServiceClient.parse_template_path(path)
+    assert expected == actual
+
+
 def test_common_billing_account_path():
-    billing_account = "cuttlefish"
+    billing_account = "squid"
     expected = "billingAccounts/{billing_account}".format(
         billing_account=billing_account,
     )
@@ -24924,7 +24950,7 @@ def test_common_billing_account_path():
 
 def test_parse_common_billing_account_path():
     expected = {
-        "billing_account": "mussel",
+        "billing_account": "clam",
     }
     path = DatasetServiceClient.common_billing_account_path(**expected)
 
@@ -24934,7 +24960,7 @@ def test_parse_common_billing_account_path():
 
 
 def test_common_folder_path():
-    folder = "winkle"
+    folder = "whelk"
     expected = "folders/{folder}".format(
         folder=folder,
     )
@@ -24944,7 +24970,7 @@ def test_common_folder_path():
 
 def test_parse_common_folder_path():
     expected = {
-        "folder": "nautilus",
+        "folder": "octopus",
     }
     path = DatasetServiceClient.common_folder_path(**expected)
 
@@ -24954,7 +24980,7 @@ def test_parse_common_folder_path():
 
 
 def test_common_organization_path():
-    organization = "scallop"
+    organization = "oyster"
     expected = "organizations/{organization}".format(
         organization=organization,
     )
@@ -24964,7 +24990,7 @@ def test_common_organization_path():
 
 def test_parse_common_organization_path():
     expected = {
-        "organization": "abalone",
+        "organization": "nudibranch",
     }
     path = DatasetServiceClient.common_organization_path(**expected)
 
@@ -24974,7 +25000,7 @@ def test_parse_common_organization_path():
 
 
 def test_common_project_path():
-    project = "squid"
+    project = "cuttlefish"
     expected = "projects/{project}".format(
         project=project,
     )
@@ -24984,7 +25010,7 @@ def test_common_project_path():
 
 def test_parse_common_project_path():
     expected = {
-        "project": "clam",
+        "project": "mussel",
     }
     path = DatasetServiceClient.common_project_path(**expected)
 
@@ -24994,8 +25020,8 @@ def test_parse_common_project_path():
 
 
 def test_common_location_path():
-    project = "whelk"
-    location = "octopus"
+    project = "winkle"
+    location = "nautilus"
     expected = "projects/{project}/locations/{location}".format(
         project=project,
         location=location,
@@ -25006,8 +25032,8 @@ def test_common_location_path():
 
 def test_parse_common_location_path():
     expected = {
-        "project": "oyster",
-        "location": "nudibranch",
+        "project": "scallop",
+        "location": "abalone",
     }
     path = DatasetServiceClient.common_location_path(**expected)
 
diff --git a/tests/unit/gapic/aiplatform_v1beta1/test_gen_ai_tuning_service.py b/tests/unit/gapic/aiplatform_v1beta1/test_gen_ai_tuning_service.py
index 620aeaa91f..698edcf9e7 100644
--- a/tests/unit/gapic/aiplatform_v1beta1/test_gen_ai_tuning_service.py
+++ b/tests/unit/gapic/aiplatform_v1beta1/test_gen_ai_tuning_service.py
@@ -4780,6 +4780,23 @@ def test_create_tuning_job_rest_call_success(request_type):
             "evaluation_config": {
                 "metrics": [
                     {
+                        "predefined_metric_spec": {
+                            "metric_spec_name": "metric_spec_name_value",
+                            "metric_spec_parameters": {"fields": {}},
+                        },
+                        "computation_based_metric_spec": {"type_": 1, "parameters": {}},
+                        "llm_based_metric_spec": {
+                            "rubric_group_key": "rubric_group_key_value",
+                            "predefined_rubric_generation_spec": {},
+                            "metric_prompt_template": "metric_prompt_template_value",
+                            "system_instruction": "system_instruction_value",
+                            "judge_autorater_config": {
+                                "sampling_count": 1507,
+                                "flip_enabled": True,
+                                "autorater_model": "autorater_model_value",
+                            },
+                            "additional_config": {},
+                        },
                         "pointwise_metric_spec": {
                             "metric_prompt_template": "metric_prompt_template_value",
                             "system_instruction": "system_instruction_value",
@@ -4805,11 +4822,7 @@ def test_create_tuning_job_rest_call_success(request_type):
                 "output_config": {
                     "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"}
                 },
-                "autorater_config": {
-                    "sampling_count": 1507,
-                    "flip_enabled": True,
-                    "autorater_model": "autorater_model_value",
-                },
+                "autorater_config": {},
             },
             "tuning_mode": 1,
         },
@@ -4910,7 +4923,7 @@ def test_create_tuning_job_rest_call_success(request_type):
                                 "function_call": {
                                     "id": "id_value",
                                     "name": "name_value",
-                                    "args": {"fields": {}},
+                                    "args": {},
                                     "partial_args": [
                                         {
                                             "null_value": 0,
@@ -6556,6 +6569,23 @@ async def test_create_tuning_job_rest_asyncio_call_success(request_type):
             "evaluation_config": {
                 "metrics": [
                     {
+                        "predefined_metric_spec": {
+                            "metric_spec_name": "metric_spec_name_value",
+                            "metric_spec_parameters": {"fields": {}},
+                        },
+                        "computation_based_metric_spec": {"type_": 1, "parameters": {}},
+                        "llm_based_metric_spec": {
+                            "rubric_group_key": "rubric_group_key_value",
+                            "predefined_rubric_generation_spec": {},
+                            "metric_prompt_template": "metric_prompt_template_value",
+                            "system_instruction": "system_instruction_value",
+                            "judge_autorater_config": {
+                                "sampling_count": 1507,
+                                "flip_enabled": True,
+                                "autorater_model": "autorater_model_value",
+                            },
+                            "additional_config": {},
+                        },
                         "pointwise_metric_spec": {
                             "metric_prompt_template": "metric_prompt_template_value",
                             "system_instruction": "system_instruction_value",
@@ -6581,11 +6611,7 @@ async def test_create_tuning_job_rest_asyncio_call_success(request_type):
                 "output_config": {
                     "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"}
                 },
-                "autorater_config": {
-                    "sampling_count": 1507,
-                    "flip_enabled": True,
-                    "autorater_model": "autorater_model_value",
-                },
+                "autorater_config": {},
             },
             "tuning_mode": 1,
         },
@@ -6686,7 +6712,7 @@ async def test_create_tuning_job_rest_asyncio_call_success(request_type):
                                 "function_call": {
                                     "id": "id_value",
                                     "name": "name_value",
-                                    "args": {"fields": {}},
+                                    "args": {},
                                     "partial_args": [
                                         {
                                             "null_value": 0,
diff --git a/tests/unit/gapic/aiplatform_v1beta1/test_job_service.py b/tests/unit/gapic/aiplatform_v1beta1/test_job_service.py
index a8ecbd6e6b..90a1a9d939 100644
--- a/tests/unit/gapic/aiplatform_v1beta1/test_job_service.py
+++ b/tests/unit/gapic/aiplatform_v1beta1/test_job_service.py
@@ -28310,6 +28310,7 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "input_config": {
             "gcs_source": {"uris": ["uris_value1", "uris_value2"]},
             "bigquery_source": {"input_uri": "input_uri_value"},
+            "vertex_multimodal_dataset_source": {"dataset_name": "dataset_name_value"},
             "instances_format": "instances_format_value",
         },
         "instance_config": {
@@ -28329,6 +28330,10 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "output_config": {
             "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"},
             "bigquery_destination": {"output_uri": "output_uri_value"},
+            "vertex_multimodal_dataset_destination": {
+                "bigquery_destination": {},
+                "display_name": "display_name_value",
+            },
             "predictions_format": "predictions_format_value",
         },
         "dedicated_resources": {
@@ -28393,6 +28398,7 @@ def test_create_batch_prediction_job_rest_call_success(request_type):
         "output_info": {
             "gcs_output_directory": "gcs_output_directory_value",
             "bigquery_output_dataset": "bigquery_output_dataset_value",
+            "vertex_multimodal_dataset_name": "vertex_multimodal_dataset_name_value",
             "bigquery_output_table": "bigquery_output_table_value",
         },
         "state": 1,
@@ -36251,6 +36257,7 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "input_config": {
             "gcs_source": {"uris": ["uris_value1", "uris_value2"]},
             "bigquery_source": {"input_uri": "input_uri_value"},
+            "vertex_multimodal_dataset_source": {"dataset_name": "dataset_name_value"},
             "instances_format": "instances_format_value",
         },
         "instance_config": {
@@ -36270,6 +36277,10 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "output_config": {
             "gcs_destination": {"output_uri_prefix": "output_uri_prefix_value"},
             "bigquery_destination": {"output_uri": "output_uri_value"},
+            "vertex_multimodal_dataset_destination": {
+                "bigquery_destination": {},
+                "display_name": "display_name_value",
+            },
             "predictions_format": "predictions_format_value",
         },
         "dedicated_resources": {
@@ -36334,6 +36345,7 @@ async def test_create_batch_prediction_job_rest_asyncio_call_success(request_typ
         "output_info": {
             "gcs_output_directory": "gcs_output_directory_value",
             "bigquery_output_dataset": "bigquery_output_dataset_value",
+            "vertex_multimodal_dataset_name": "vertex_multimodal_dataset_name_value",
             "bigquery_output_table": "bigquery_output_table_value",
         },
         "state": 1,
diff --git a/tests/unit/gapic/aiplatform_v1beta1/test_schedule_service.py b/tests/unit/gapic/aiplatform_v1beta1/test_schedule_service.py
index a3307d5186..efbf062810 100644
--- a/tests/unit/gapic/aiplatform_v1beta1/test_schedule_service.py
+++ b/tests/unit/gapic/aiplatform_v1beta1/test_schedule_service.py
@@ -1414,6 +1414,7 @@ def test_create_schedule(request_type, transport: str = "grpc"):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -1434,6 +1435,7 @@ def test_create_schedule(request_type, transport: str = "grpc"):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -1567,6 +1569,7 @@ async def test_create_schedule_async(
                 started_run_count=1843,
                 state=gca_schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -1587,6 +1590,7 @@ async def test_create_schedule_async(
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -2103,6 +2107,7 @@ def test_get_schedule(request_type, transport: str = "grpc"):
             started_run_count=1843,
             state=schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -2123,6 +2128,7 @@ def test_get_schedule(request_type, transport: str = "grpc"):
     assert response.started_run_count == 1843
     assert response.state == schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -2256,6 +2262,7 @@ async def test_get_schedule_async(
                 started_run_count=1843,
                 state=schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -2276,6 +2283,7 @@ async def test_get_schedule_async(
     assert response.started_run_count == 1843
     assert response.state == schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -3606,6 +3614,7 @@ def test_update_schedule(request_type, transport: str = "grpc"):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -3626,6 +3635,7 @@ def test_update_schedule(request_type, transport: str = "grpc"):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -3755,6 +3765,7 @@ async def test_update_schedule_async(
                 started_run_count=1843,
                 state=gca_schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -3775,6 +3786,7 @@ async def test_update_schedule_async(
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -5574,6 +5586,7 @@ async def test_create_schedule_empty_call_grpc_asyncio():
                 started_run_count=1843,
                 state=gca_schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -5633,6 +5646,7 @@ async def test_get_schedule_empty_call_grpc_asyncio():
                 started_run_count=1843,
                 state=schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -5740,6 +5754,7 @@ async def test_update_schedule_empty_call_grpc_asyncio():
                 started_run_count=1843,
                 state=gca_schedule.Schedule.State.ACTIVE,
                 max_concurrent_run_count=2596,
+                max_concurrent_active_run_count=3327,
                 allow_queueing=True,
                 catch_up=True,
             )
@@ -6162,6 +6177,7 @@ def test_create_schedule_rest_call_success(request_type):
         "last_pause_time": {},
         "last_resume_time": {},
         "max_concurrent_run_count": 2596,
+        "max_concurrent_active_run_count": 3327,
         "allow_queueing": True,
         "catch_up": True,
         "last_scheduled_run_response": {
@@ -6248,6 +6264,7 @@ def get_message_fields(field):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -6273,6 +6290,7 @@ def get_message_fields(field):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -6513,6 +6531,7 @@ def test_get_schedule_rest_call_success(request_type):
             started_run_count=1843,
             state=schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -6538,6 +6557,7 @@ def test_get_schedule_rest_call_success(request_type):
     assert response.started_run_count == 1843
     assert response.state == schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -7359,6 +7379,7 @@ def test_update_schedule_rest_call_success(request_type):
         "last_pause_time": {},
         "last_resume_time": {},
         "max_concurrent_run_count": 2596,
+        "max_concurrent_active_run_count": 3327,
         "allow_queueing": True,
         "catch_up": True,
         "last_scheduled_run_response": {
@@ -7445,6 +7466,7 @@ def get_message_fields(field):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -7470,6 +7492,7 @@ def get_message_fields(field):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -8746,6 +8769,7 @@ async def test_create_schedule_rest_asyncio_call_success(request_type):
         "last_pause_time": {},
         "last_resume_time": {},
         "max_concurrent_run_count": 2596,
+        "max_concurrent_active_run_count": 3327,
         "allow_queueing": True,
         "catch_up": True,
         "last_scheduled_run_response": {
@@ -8832,6 +8856,7 @@ def get_message_fields(field):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -8859,6 +8884,7 @@ def get_message_fields(field):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -9135,6 +9161,7 @@ async def test_get_schedule_rest_asyncio_call_success(request_type):
             started_run_count=1843,
             state=schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -9162,6 +9189,7 @@ async def test_get_schedule_rest_asyncio_call_success(request_type):
     assert response.started_run_count == 1843
     assert response.state == schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True
 
@@ -10055,6 +10083,7 @@ async def test_update_schedule_rest_asyncio_call_success(request_type):
         "last_pause_time": {},
         "last_resume_time": {},
         "max_concurrent_run_count": 2596,
+        "max_concurrent_active_run_count": 3327,
         "allow_queueing": True,
         "catch_up": True,
         "last_scheduled_run_response": {
@@ -10141,6 +10170,7 @@ def get_message_fields(field):
             started_run_count=1843,
             state=gca_schedule.Schedule.State.ACTIVE,
             max_concurrent_run_count=2596,
+            max_concurrent_active_run_count=3327,
             allow_queueing=True,
             catch_up=True,
             cron="cron_value",
@@ -10168,6 +10198,7 @@ def get_message_fields(field):
     assert response.started_run_count == 1843
     assert response.state == gca_schedule.Schedule.State.ACTIVE
     assert response.max_concurrent_run_count == 2596
+    assert response.max_concurrent_active_run_count == 3327
     assert response.allow_queueing is True
     assert response.catch_up is True