feat: Add SchemaViolationReason to IngestionFailureEvent (#1411)

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Andrew Browne <81702808+abbrowne126@users.noreply.github.com>

Author: gcf-owl-bot[bot]

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