feat: Add SchemaViolationReason to IngestionFailureEvent (#1411)

gcf-owl-bot[bot] · abbrowne126 · web-flow · commit c046ca22e9bd · 2025-06-06T17:03:00.000-07:00
Co-authored-by: Owl Bot &lt;gcf-owl-bot[bot]@users.noreply.github.com&gt;
Co-authored-by: Andrew Browne &lt;81702808+abbrowne126@users.noreply.github.com&gt;
diff --git a/google/pubsub_v1/services/subscriber/async_client.py b/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.
diff --git a/google/pubsub_v1/services/subscriber/client.py b/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.
diff --git a/google/pubsub_v1/services/subscriber/transports/grpc.py b/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
diff --git a/google/pubsub_v1/services/subscriber/transports/grpc_asyncio.py b/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
diff --git a/google/pubsub_v1/types/pubsub.py b/google/pubsub_v1/types/pubsub.py
