Merge branch 'main' into onboard-librarian-generate

Author: parthea

.github/.OwlBot.lock.yaml

@@ -1,4 +1,4 @@
 {
-    ".": "2.32.0"
+    ".": "2.33.0"
 }
 

.github/.OwlBot.yaml

@@ -5,6 +5,25 @@
 [1]: https://pypi.org/project/google-cloud-pubsub/#history
 
 
+## [2.33.0](https://github.com/googleapis/python-pubsub/compare/v2.32.0...v2.33.0) (2025-10-30)
+
+
+### Features
+
+* Add AwsKinesisFailureReason.ApiViolationReason ([ac68093](https://github.com/googleapis/python-pubsub/commit/ac6809350758306f28fa1ab46939bc438b5a5e19))
+* Add tags to Subscription, Topic, and CreateSnapshotRequest messages for use in CreateSubscription, CreateTopic, and CreateSnapshot requests respectively ([ac68093](https://github.com/googleapis/python-pubsub/commit/ac6809350758306f28fa1ab46939bc438b5a5e19))
+* Annotate some resource fields with their corresponding API types ([ac68093](https://github.com/googleapis/python-pubsub/commit/ac6809350758306f28fa1ab46939bc438b5a5e19))
+
+
+### Bug Fixes
+
+* Deprecate credentials_file argument ([ac68093](https://github.com/googleapis/python-pubsub/commit/ac6809350758306f28fa1ab46939bc438b5a5e19))
+
+
+### Documentation
+
+* A comment for field `received_messages` in message `.google.pubsub.v1.StreamingPullResponse` is changed ([ac68093](https://github.com/googleapis/python-pubsub/commit/ac6809350758306f28fa1ab46939bc438b5a5e19))
+
 ## [2.32.0](https://github.com/googleapis/python-pubsub/compare/v2.31.1...v2.32.0) (2025-10-28)
 
 

.github/release-please.yml

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.32.0"  # {x-release-please-version}
+__version__ = "2.33.0"  # {x-release-please-version}

.github/release-trigger.yml

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.32.0"  # {x-release-please-version}
+__version__ = "2.33.0"  # {x-release-please-version}

.release-please-manifest.json

@@ -80,8 +80,12 @@ class PublisherAsyncClient:
     _DEFAULT_ENDPOINT_TEMPLATE = PublisherClient._DEFAULT_ENDPOINT_TEMPLATE
     _DEFAULT_UNIVERSE = PublisherClient._DEFAULT_UNIVERSE
 
+    crypto_key_path = staticmethod(PublisherClient.crypto_key_path)
+    parse_crypto_key_path = staticmethod(PublisherClient.parse_crypto_key_path)
     schema_path = staticmethod(PublisherClient.schema_path)
     parse_schema_path = staticmethod(PublisherClient.parse_schema_path)
+    snapshot_path = staticmethod(PublisherClient.snapshot_path)
+    parse_snapshot_path = staticmethod(PublisherClient.parse_snapshot_path)
     subscription_path = staticmethod(PublisherClient.subscription_path)
     parse_subscription_path = staticmethod(PublisherClient.parse_subscription_path)
     topic_path = staticmethod(PublisherClient.topic_path)

CHANGELOG.md

@@ -215,6 +215,30 @@ def transport(self) -> PublisherTransport:
         """
         return self._transport
 
+    @staticmethod
+    def crypto_key_path(
+        project: str,
+        location: str,
+        key_ring: str,
+        crypto_key: str,
+    ) -> str:
+        """Returns a fully-qualified crypto_key string."""
+        return "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}".format(
+            project=project,
+            location=location,
+            key_ring=key_ring,
+            crypto_key=crypto_key,
+        )
+
+    @staticmethod
+    def parse_crypto_key_path(path: str) -> Dict[str, str]:
+        """Parses a crypto_key path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/keyRings/(?P<key_ring>.+?)/cryptoKeys/(?P<crypto_key>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def schema_path(
         project: str,
@@ -232,6 +256,23 @@ def parse_schema_path(path: str) -> Dict[str, str]:
         m = re.match(r"^projects/(?P<project>.+?)/schemas/(?P<schema>.+?)$", path)
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def snapshot_path(
+        project: str,
+        snapshot: str,
+    ) -> str:
+        """Returns a fully-qualified snapshot string."""
+        return "projects/{project}/snapshots/{snapshot}".format(
+            project=project,
+            snapshot=snapshot,
+        )
+
+    @staticmethod
+    def parse_snapshot_path(path: str) -> Dict[str, str]:
+        """Parses a snapshot path into its component segments."""
+        m = re.match(r"^projects/(?P<project>.+?)/snapshots/(?P<snapshot>.+?)$", path)
+        return m.groupdict() if m else {}
+
     @staticmethod
     def subscription_path(
         project: str,