Merge branch 'main' into surface-stream-closures

Author: abbrowne126

.release-please-manifest.json

@@ -1,4 +1,4 @@
 {
-    ".": "2.29.0"
+    ".": "2.30.0"
 }
 

CHANGELOG.md

@@ -5,6 +5,27 @@
 [1]: https://pypi.org/project/google-cloud-pubsub/#history
 
 
+## [2.30.0](https://github.com/googleapis/python-pubsub/compare/v2.29.1...v2.30.0) (2025-06-07)
+
+
+### Features
+
+* Add SchemaViolationReason to IngestionFailureEvent ([#1411](https://github.com/googleapis/python-pubsub/issues/1411)) ([c046ca2](https://github.com/googleapis/python-pubsub/commit/c046ca22e9bddff6b50f7670bf6b9b9470bf78e8))
+
+## [2.29.1](https://github.com/googleapis/python-pubsub/compare/v2.29.0...v2.29.1) (2025-05-23)
+
+
+### Bug Fixes
+
+* Remove setup.cfg configuration for creating universal wheels ([#1376](https://github.com/googleapis/python-pubsub/issues/1376)) ([60639c4](https://github.com/googleapis/python-pubsub/commit/60639c4928105ae8a72c8e37b1f48f75cc2ffcc3))
+
+
+### Documentation
+
+* **sample:** Add samples for topic and subscription SMTs ([#1386](https://github.com/googleapis/python-pubsub/issues/1386)) ([4d072e0](https://github.com/googleapis/python-pubsub/commit/4d072e088b59f692dc3d59c3197a2993c125917e))
+* Update documentation for JavaScriptUDF to indicate that the `message_id` metadata field is optional instead of required ([#1380](https://github.com/googleapis/python-pubsub/issues/1380)) ([be90054](https://github.com/googleapis/python-pubsub/commit/be9005412fea06bea917c8b6861546b7e6c62a1e))
+* Update readme links ([#1409](https://github.com/googleapis/python-pubsub/issues/1409)) ([77ba05d](https://github.com/googleapis/python-pubsub/commit/77ba05d4ba5b84a25c1a07c5397bbc184fa6041d))
+
 ## [2.29.0](https://github.com/googleapis/python-pubsub/compare/v2.28.0...v2.29.0) (2025-03-19)
 
 

google/pubsub/gapic_version.py

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

google/pubsub_v1/gapic_version.py

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

google/pubsub_v1/services/subscriber/async_client.py

@@ -1377,7 +1377,7 @@ def streaming_pull(
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> Awaitable[AsyncIterable[pubsub.StreamingPullResponse]]:
         r"""Establishes a stream with the server, which sends messages down
-        to the client. The client streams acknowledgements and ack
+        to the client. The client streams acknowledgments and ack
         deadline modifications back to the server. The server will close
         the stream and return the status on any error. The server may
         close the stream with status ``UNAVAILABLE`` to reassign
@@ -1427,7 +1427,7 @@ def request_generator():
             requests (AsyncIterator[`google.pubsub_v1.types.StreamingPullRequest`]):
                 The request object AsyncIterator. Request for the ``StreamingPull`` streaming RPC method.
                 This request is used to establish the initial stream as
-                well as to stream acknowledgements and ack deadline
+                well as to stream acknowledgments and ack deadline
                 modifications from the client to the server.
             retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
                 should be retried.

google/pubsub_v1/services/subscriber/client.py

@@ -1827,7 +1827,7 @@ def streaming_pull(
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> Iterable[pubsub.StreamingPullResponse]:
         r"""Establishes a stream with the server, which sends messages down
-        to the client. The client streams acknowledgements and ack
+        to the client. The client streams acknowledgments and ack
         deadline modifications back to the server. The server will close
         the stream and return the status on any error. The server may
         close the stream with status ``UNAVAILABLE`` to reassign
@@ -1877,7 +1877,7 @@ def request_generator():
             requests (Iterator[google.pubsub_v1.types.StreamingPullRequest]):
                 The request object iterator. Request for the ``StreamingPull`` streaming RPC method.
                 This request is used to establish the initial stream as
-                well as to stream acknowledgements and ack deadline
+                well as to stream acknowledgments and ack deadline
                 modifications from the client to the server.
             retry (google.api_core.retry.Retry): Designation of what errors, if any,
                 should be retried.

google/pubsub_v1/services/subscriber/transports/grpc.py

@@ -571,7 +571,7 @@ def streaming_pull(
         r"""Return a callable for the streaming pull method over gRPC.
 
         Establishes a stream with the server, which sends messages down
-        to the client. The client streams acknowledgements and ack
+        to the client. The client streams acknowledgments and ack
         deadline modifications back to the server. The server will close
         the stream and return the status on any error. The server may
         close the stream with status ``UNAVAILABLE`` to reassign

google/pubsub_v1/services/subscriber/transports/grpc_asyncio.py

@@ -585,7 +585,7 @@ def streaming_pull(
         r"""Return a callable for the streaming pull method over gRPC.
 
         Establishes a stream with the server, which sends messages down
-        to the client. The client streams acknowledgements and ack
+        to the client. The client streams acknowledgments and ack
         deadline modifications back to the server. The server will close
         the stream and return the status on any error. The server may
         close the stream with status ``UNAVAILABLE`` to reassign