🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Author: gcf-owl-bot[bot]

google/pubsub_v1/services/publisher/async_client.py

@@ -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)

google/pubsub_v1/services/publisher/client.py

@@ -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,

google/pubsub_v1/services/subscriber/async_client.py

@@ -86,6 +86,8 @@ class SubscriberAsyncClient:
     _DEFAULT_ENDPOINT_TEMPLATE = SubscriberClient._DEFAULT_ENDPOINT_TEMPLATE
     _DEFAULT_UNIVERSE = SubscriberClient._DEFAULT_UNIVERSE
 
+    listing_path = staticmethod(SubscriberClient.listing_path)
+    parse_listing_path = staticmethod(SubscriberClient.parse_listing_path)
     snapshot_path = staticmethod(SubscriberClient.snapshot_path)
     parse_snapshot_path = staticmethod(SubscriberClient.parse_snapshot_path)
     subscription_path = staticmethod(SubscriberClient.subscription_path)

google/pubsub_v1/services/subscriber/client.py

@@ -219,6 +219,30 @@ def transport(self) -> SubscriberTransport:
         """
         return self._transport
 
+    @staticmethod
+    def listing_path(
+        project: str,
+        location: str,
+        data_exchange: str,
+        listing: str,
+    ) -> str:
+        """Returns a fully-qualified listing string."""
+        return "projects/{project}/locations/{location}/dataExchanges/{data_exchange}/listings/{listing}".format(
+            project=project,
+            location=location,
+            data_exchange=data_exchange,
+            listing=listing,
+        )
+
+    @staticmethod
+    def parse_listing_path(path: str) -> Dict[str, str]:
+        """Parses a listing path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/dataExchanges/(?P<data_exchange>.+?)/listings/(?P<listing>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def snapshot_path(
         project: str,

google/pubsub_v1/types/pubsub.py

@@ -1210,6 +1210,13 @@ class AwsKinesisFailureReason(proto.Message):
                 Optional. Failure encountered when applying a
                 message transformation to the Pub/Sub message.
 
+                This field is a member of `oneof`_ ``reason``.
+            api_violation_reason (google.pubsub_v1.types.IngestionFailureEvent.ApiViolationReason):
+                Optional. The message failed to be published
+                due to an API violation. This is only set when
+                the size of the data field of the Kinesis record
+                is zero.
+
                 This field is a member of `oneof`_ ``reason``.
         """
 
@@ -1239,6 +1246,12 @@ class AwsKinesisFailureReason(proto.Message):
             oneof="reason",
             message="IngestionFailureEvent.MessageTransformationFailureReason",
         )
+        api_violation_reason: "IngestionFailureEvent.ApiViolationReason" = proto.Field(
+            proto.MESSAGE,
+            number=6,
+            oneof="reason",
+            message="IngestionFailureEvent.ApiViolationReason",
+        )
 
     topic: str = proto.Field(
         proto.STRING,
@@ -1423,6 +1436,13 @@ class Topic(proto.Message):
             Optional. Transforms to be applied to
             messages published to the topic. Transforms are
             applied in the order specified.
+        tags (MutableMapping[str, str]):
+            Optional. Input only. Immutable. Tag
+            keys/values directly bound to this resource. For
+            example:
+
+              "123/environment": "production",
+              "123/costCenter": "marketing".
     """
 
     class State(proto.Enum):
@@ -1491,6 +1511,11 @@ class State(proto.Enum):
         number=13,
         message="MessageTransform",
     )
+    tags: MutableMapping[str, str] = proto.MapField(
+        proto.STRING,
+        proto.STRING,
+        number=14,
+    )
 
 
 class PubsubMessage(proto.Message):
@@ -2024,6 +2049,13 @@ class Subscription(proto.Message):
             messages before they are delivered to
             subscribers. Transforms are applied in the order
             specified.
+        tags (MutableMapping[str, str]):
+            Optional. Input only. Immutable. Tag
+            keys/values directly bound to this resource. For
+            example:
+
+              "123/environment": "production",
+              "123/costCenter": "marketing".
     """
 
     class State(proto.Enum):
@@ -2162,6 +2194,11 @@ class AnalyticsHubSubscriptionInfo(proto.Message):
         number=25,
         message="MessageTransform",
     )
+    tags: MutableMapping[str, str] = proto.MapField(
+        proto.STRING,
+        proto.STRING,
+        number=26,
+    )
 
 
 class RetryPolicy(proto.Message):
@@ -3161,8 +3198,7 @@ class StreamingPullResponse(proto.Message):
 
     Attributes:
         received_messages (MutableSequence[google.pubsub_v1.types.ReceivedMessage]):
-            Optional. Received Pub/Sub messages. This
-            will not be empty.
+            Optional. Received Pub/Sub messages.
         acknowledge_confirmation (google.pubsub_v1.types.StreamingPullResponse.AcknowledgeConfirmation):
             Optional. This field will only be set if
             ``enable_exactly_once_delivery`` is set to ``true`` and is
@@ -3312,6 +3348,13 @@ class CreateSnapshotRequest(proto.Message):
         labels (MutableMapping[str, str]):
             Optional. See `Creating and managing
             labels <https://cloud.google.com/pubsub/docs/labels>`__.
+        tags (MutableMapping[str, str]):
+            Optional. Input only. Immutable. Tag
+            keys/values directly bound to this resource. For
+            example:
+
+              "123/environment": "production",
+              "123/costCenter": "marketing".
     """
 
     name: str = proto.Field(
@@ -3327,6 +3370,11 @@ class CreateSnapshotRequest(proto.Message):
         proto.STRING,
         number=3,
     )
+    tags: MutableMapping[str, str] = proto.MapField(
+        proto.STRING,
+        proto.STRING,
+        number=4,
+    )
 
 
 class UpdateSnapshotRequest(proto.Message):