googleapis
diff --git a/‎.librarian/generator-input/librarian.py‎
Lines changed: 2 additions & 2 deletions b/‎.librarian/generator-input/librarian.py‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎.librarian/state.yaml‎
Lines changed: 1 addition & 1 deletion b/‎.librarian/state.yaml‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎google/pubsub/__init__.py‎
Lines changed: 2 additions & 0 deletions b/‎google/pubsub/__init__.py‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎google/pubsub_v1/__init__.py‎
Lines changed: 2 additions & 0 deletions b/‎google/pubsub_v1/__init__.py‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎google/pubsub_v1/services/publisher/async_client.py‎
Lines changed: 8 additions & 8 deletions b/‎google/pubsub_v1/services/publisher/async_client.py‎
Lines changed: 8 additions & 8 deletions
diff --git a/‎google/pubsub_v1/services/publisher/client.py‎
Lines changed: 8 additions & 8 deletions b/‎google/pubsub_v1/services/publisher/client.py‎
Lines changed: 8 additions & 8 deletions
diff --git a/‎google/pubsub_v1/services/subscriber/async_client.py‎
Lines changed: 2 additions & 2 deletions b/‎google/pubsub_v1/services/subscriber/async_client.py‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎google/pubsub_v1/services/subscriber/client.py‎
Lines changed: 2 additions & 2 deletions b/‎google/pubsub_v1/services/subscriber/client.py‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎google/pubsub_v1/types/__init__.py‎
Lines changed: 2 additions & 0 deletions b/‎google/pubsub_v1/types/__init__.py‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎google/pubsub_v1/types/pubsub.py‎
Lines changed: 116 additions & 10 deletions b/‎google/pubsub_v1/types/pubsub.py‎
Lines changed: 116 additions & 10 deletions
@@ -338,10 +338,10 @@
     samples=True,
     cov_level=99,
     versions=gcp.common.detect_versions(path="./google", default_first=True),
-    unit_test_python_versions=["3.7", "3.8", "3.9", "3.10", "3.11", "3.12", "3.13", "3.14"],
+    unit_test_python_versions=["3.9", "3.10", "3.11", "3.12", "3.13", "3.14"],
     unit_test_dependencies=["flaky"],
     system_test_python_versions=["3.12"],
-    system_test_external_dependencies=["psutil","flaky"],
+    system_test_external_dependencies=["psutil", "flaky"],
 )
 s.move(templated_files, excludes=[".coveragerc", ".github/**", "README.rst", "docs/**", ".kokoro/**"])
 
 
@@ -2,7 +2,7 @@ image: us-central1-docker.pkg.dev/cloud-sdk-librarian-prod/images-prod/python-li
 libraries:
   - id: google-cloud-pubsub
     version: 2.34.0
-    last_generated_commit: 9fcfbea0aa5b50fa22e190faceb073d74504172b
+    last_generated_commit: 2d0b3a154fb4f56993487c5409850ad3431a2690
     apis:
       - path: google/pubsub/v1
         service_config: pubsub_v1.yaml
 
@@ -28,6 +28,7 @@
 from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
 
 from google.pubsub_v1.types.pubsub import AcknowledgeRequest
+from google.pubsub_v1.types.pubsub import AIInference
 from google.pubsub_v1.types.pubsub import BigQueryConfig
 from google.pubsub_v1.types.pubsub import CloudStorageConfig
 from google.pubsub_v1.types.pubsub import CreateSnapshotRequest
@@ -104,6 +105,7 @@
     "SubscriberClient",
     "SubscriberAsyncClient",
     "AcknowledgeRequest",
+    "AIInference",
     "BigQueryConfig",
     "CloudStorageConfig",
     "CreateSnapshotRequest",
 
@@ -36,6 +36,7 @@
 from .services.subscriber import SubscriberAsyncClient
 
 from .types.pubsub import AcknowledgeRequest
+from .types.pubsub import AIInference
 from .types.pubsub import BigQueryConfig
 from .types.pubsub import CloudStorageConfig
 from .types.pubsub import CreateSnapshotRequest
@@ -202,6 +203,7 @@ def _get_version(dependency_name):
     "PublisherAsyncClient",
     "SchemaServiceAsyncClient",
     "SubscriberAsyncClient",
+    "AIInference",
     "AcknowledgeRequest",
     "BigQueryConfig",
     "CloudStorageConfig",
 
@@ -339,14 +339,14 @@ async def sample_create_topic():
             request (Optional[Union[google.pubsub_v1.types.Topic, dict]]):
                 The request object. A topic resource.
             name (:class:`str`):
-                Required. The name of the topic. It must have the format
-                ``"projects/{project}/topics/{topic}"``. ``{topic}``
-                must start with a letter, and contain only letters
-                (``[A-Za-z]``), numbers (``[0-9]``), dashes (``-``),
-                underscores (``_``), periods (``.``), tildes (``~``),
-                plus (``+``) or percent signs (``%``). It must be
-                between 3 and 255 characters in length, and it must not
-                start with ``"goog"``.
+                Required. Identifier. The name of the topic. It must
+                have the format ``"projects/{project}/topics/{topic}"``.
+                ``{topic}`` must start with a letter, and contain only
+                letters (``[A-Za-z]``), numbers (``[0-9]``), dashes
+                (``-``), underscores (``_``), periods (``.``), tildes
+                (``~``), plus (``+``) or percent signs (``%``). It must
+                be between 3 and 255 characters in length, and it must
+                not start with ``"goog"``.
 
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
 
@@ -868,14 +868,14 @@ def sample_create_topic():
             request (Union[google.pubsub_v1.types.Topic, dict]):
                 The request object. A topic resource.
             name (str):
-                Required. The name of the topic. It must have the format
-                ``"projects/{project}/topics/{topic}"``. ``{topic}``
-                must start with a letter, and contain only letters
-                (``[A-Za-z]``), numbers (``[0-9]``), dashes (``-``),
-                underscores (``_``), periods (``.``), tildes (``~``),
-                plus (``+``) or percent signs (``%``). It must be
-                between 3 and 255 characters in length, and it must not
-                start with ``"goog"``.
+                Required. Identifier. The name of the topic. It must
+                have the format ``"projects/{project}/topics/{topic}"``.
+                ``{topic}`` must start with a letter, and contain only
+                letters (``[A-Za-z]``), numbers (``[0-9]``), dashes
+                (``-``), underscores (``_``), periods (``.``), tildes
+                (``~``), plus (``+``) or percent signs (``%``). It must
+                be between 3 and 255 characters in length, and it must
+                not start with ``"goog"``.
 
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
 
@@ -360,8 +360,8 @@ async def sample_create_subscription():
                 then the subscriber will pull and ack messages using API
                 methods. At most one of these fields may be set.
             name (:class:`str`):
-                Required. The name of the subscription. It must have the
-                format
+                Required. Identifier. The name of the subscription. It
+                must have the format
                 ``"projects/{project}/subscriptions/{subscription}"``.
                 ``{subscription}`` must start with a letter, and contain
                 only letters (``[A-Za-z]``), numbers (``[0-9]``), dashes
 
@@ -872,8 +872,8 @@ def sample_create_subscription():
                 then the subscriber will pull and ack messages using API
                 methods. At most one of these fields may be set.
             name (str):
-                Required. The name of the subscription. It must have the
-                format
+                Required. Identifier. The name of the subscription. It
+                must have the format
                 ``"projects/{project}/subscriptions/{subscription}"``.
                 ``{subscription}`` must start with a letter, and contain
                 only letters (``[A-Za-z]``), numbers (``[0-9]``), dashes
 
@@ -17,6 +17,7 @@
 
 from .pubsub import (
     AcknowledgeRequest,
+    AIInference,
     BigQueryConfig,
     CloudStorageConfig,
     CreateSnapshotRequest,
@@ -99,6 +100,7 @@
 __all__ = (
     "TimeoutType",
     "AcknowledgeRequest",
+    "AIInference",
     "BigQueryConfig",
     "CloudStorageConfig",
     "CreateSnapshotRequest",
 
@@ -21,6 +21,7 @@
 
 from google.protobuf import duration_pb2  # type: ignore
 from google.protobuf import field_mask_pb2  # type: ignore
+from google.protobuf import struct_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
 from google.pubsub_v1.types import schema as gp_schema
 
@@ -34,6 +35,7 @@
         "PlatformLogsSettings",
         "IngestionFailureEvent",
         "JavaScriptUDF",
+        "AIInference",
         "MessageTransform",
         "Topic",
         "PubsubMessage",
@@ -1344,9 +1346,78 @@ class JavaScriptUDF(proto.Message):
     )
 
 
+class AIInference(proto.Message):
+    r"""Configuration for making inference requests against Vertex AI
+    models.
+
+
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
+    Attributes:
+        endpoint (str):
+            Required. An endpoint to a Vertex AI model of the form
+            ``projects/{project}/locations/{location}/endpoints/{endpoint}``
+            or
+            ``projects/{project}/locations/{location}/publishers/{publisher}/models/{model}``.
+            Vertex AI API requests will be sent to this endpoint.
+        unstructured_inference (google.pubsub_v1.types.AIInference.UnstructuredInference):
+            Optional. Requests and responses can be any
+            arbitrary JSON object.
+
+            This field is a member of `oneof`_ ``inference_mode``.
+        service_account_email (str):
+            Optional. The service account to use to make prediction
+            requests against endpoints. The resource creator or updater
+            that specifies this field must have
+            ``iam.serviceAccounts.actAs`` permission on the service
+            account. If not specified, the Pub/Sub `service
+            agent <{$universe.dns_names.final_documentation_domain}/iam/docs/service-agents>`__,
+            service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com,
+            is used.
+    """
+
+    class UnstructuredInference(proto.Message):
+        r"""Configuration for making inferences using arbitrary JSON
+        payloads.
+
+        Attributes:
+            parameters (google.protobuf.struct_pb2.Struct):
+                Optional. A parameters object to be included
+                in each inference request. The parameters object
+                is combined with the data field of the Pub/Sub
+                message to form the inference request.
+        """
+
+        parameters: struct_pb2.Struct = proto.Field(
+            proto.MESSAGE,
+            number=1,
+            message=struct_pb2.Struct,
+        )
+
+    endpoint: str = proto.Field(
+        proto.STRING,
+        number=1,
+    )
+    unstructured_inference: UnstructuredInference = proto.Field(
+        proto.MESSAGE,
+        number=2,
+        oneof="inference_mode",
+        message=UnstructuredInference,
+    )
+    service_account_email: str = proto.Field(
+        proto.STRING,
+        number=3,
+    )
+
+
 class MessageTransform(proto.Message):
     r"""All supported message transforms types.
 
+    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:
@@ -1355,6 +1426,13 @@ class MessageTransform(proto.Message):
             JavaScriptUDF's are specified on a resource, each must have
             a unique ``function_name``.
 
+            This field is a member of `oneof`_ ``transform``.
+        ai_inference (google.pubsub_v1.types.AIInference):
+            Optional. AI Inference. Specifies the Vertex
+            AI endpoint that inference requests built from
+            the Pub/Sub message data and provided parameters
+            will be sent to.
+
             This field is a member of `oneof`_ ``transform``.
         enabled (bool):
             Optional. This field is deprecated, use the ``disabled``
@@ -1370,6 +1448,12 @@ class MessageTransform(proto.Message):
         oneof="transform",
         message="JavaScriptUDF",
     )
+    ai_inference: "AIInference" = proto.Field(
+        proto.MESSAGE,
+        number=6,
+        oneof="transform",
+        message="AIInference",
+    )
     enabled: bool = proto.Field(
         proto.BOOL,
         number=3,
@@ -1385,10 +1469,10 @@ class Topic(proto.Message):
 
     Attributes:
         name (str):
-            Required. The name of the topic. It must have the format
-            ``"projects/{project}/topics/{topic}"``. ``{topic}`` must
-            start with a letter, and contain only letters
-            (``[A-Za-z]``), numbers (``[0-9]``), dashes (``-``),
+            Required. Identifier. The name of the topic. It must have
+            the format ``"projects/{project}/topics/{topic}"``.
+            ``{topic}`` must start with a letter, and contain only
+            letters (``[A-Za-z]``), numbers (``[0-9]``), dashes (``-``),
             underscores (``_``), periods (``.``), tildes (``~``), plus
             (``+``) or percent signs (``%``). It must be between 3 and
             255 characters in length, and it must not start with
@@ -1442,7 +1526,11 @@ class Topic(proto.Message):
             example:
 
               "123/environment": "production",
-              "123/costCenter": "marketing".
+              "123/costCenter": "marketing"
+            See
+            https://docs.cloud.google.com/pubsub/docs/tags
+            for more information on using tags with Pub/Sub
+            resources.
     """
 
     class State(proto.Enum):
@@ -1889,8 +1977,8 @@ class Subscription(proto.Message):
 
     Attributes:
         name (str):
-            Required. The name of the subscription. It must have the
-            format
+            Required. Identifier. The name of the subscription. It must
+            have the format
             ``"projects/{project}/subscriptions/{subscription}"``.
             ``{subscription}`` must start with a letter, and contain
             only letters (``[A-Za-z]``), numbers (``[0-9]``), dashes
@@ -2043,7 +2131,7 @@ class Subscription(proto.Message):
         analytics_hub_subscription_info (google.pubsub_v1.types.Subscription.AnalyticsHubSubscriptionInfo):
             Output only. Information about the associated
             Analytics Hub subscription. Only set if the
-            subscritpion is created by Analytics Hub.
+            subscription is created by Analytics Hub.
         message_transforms (MutableSequence[google.pubsub_v1.types.MessageTransform]):
             Optional. Transforms to be applied to
             messages before they are delivered to
@@ -2055,7 +2143,11 @@ class Subscription(proto.Message):
             example:
 
               "123/environment": "production",
-              "123/costCenter": "marketing".
+              "123/costCenter": "marketing"
+            See
+            https://docs.cloud.google.com/pubsub/docs/tags
+            for more information on using tags with Pub/Sub
+            resources.
     """
 
     class State(proto.Enum):
@@ -2530,13 +2622,18 @@ class State(proto.Enum):
                 Cannot write to the destination because enforce_in_transit
                 is set to true and the destination locations are not in the
                 allowed regions.
+            VERTEX_AI_LOCATION_RESTRICTION (6):
+                Cannot write to the BigQuery table because the table is not
+                in the same location as where Vertex AI models used in
+                ``message_transform``\ s are deployed.
         """
         STATE_UNSPECIFIED = 0
         ACTIVE = 1
         PERMISSION_DENIED = 2
         NOT_FOUND = 3
         SCHEMA_MISMATCH = 4
         IN_TRANSIT_LOCATION_RESTRICTION = 5
+        VERTEX_AI_LOCATION_RESTRICTION = 6
 
     table: str = proto.Field(
         proto.STRING,
@@ -2663,13 +2760,18 @@ class State(proto.Enum):
                 Cannot write to the Cloud Storage bucket due
                 to an incompatibility between the topic schema
                 and subscription settings.
+            VERTEX_AI_LOCATION_RESTRICTION (6):
+                Cannot write to the Cloud Storage bucket because the bucket
+                is not in the same location as where Vertex AI models used
+                in ``message_transform``\ s are deployed.
         """
         STATE_UNSPECIFIED = 0
         ACTIVE = 1
         PERMISSION_DENIED = 2
         NOT_FOUND = 3
         IN_TRANSIT_LOCATION_RESTRICTION = 4
         SCHEMA_MISMATCH = 5
+        VERTEX_AI_LOCATION_RESTRICTION = 6
 
     class TextConfig(proto.Message):
         r"""Configuration for writing message data in text format.
@@ -3354,7 +3456,11 @@ class CreateSnapshotRequest(proto.Message):
             example:
 
               "123/environment": "production",
-              "123/costCenter": "marketing".
+              "123/costCenter": "marketing"
+            See
+            https://docs.cloud.google.com/pubsub/docs/tags
+            for more information on using tags with Pub/Sub
+            resources.
     """
 
     name: str = proto.Field(