Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitc046ca2

Browse files
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>
1 parent42d32de commitc046ca2

File tree

5 files changed

+154
-27
lines changed

5 files changed

+154
-27
lines changed

‎google/pubsub_v1/services/subscriber/async_client.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1377,7 +1377,7 @@ def streaming_pull(
13771377
metadata:Sequence[Tuple[str,Union[str,bytes]]]= (),
13781378
)->Awaitable[AsyncIterable[pubsub.StreamingPullResponse]]:
13791379
r"""Establishes a stream with the server, which sends messages down
1380-
to the client. The client streamsacknowledgements and ack
1380+
to the client. The client streamsacknowledgments and ack
13811381
deadline modifications back to the server. The server will close
13821382
the stream and return the status on any error. The server may
13831383
close the stream with status ``UNAVAILABLE`` to reassign
@@ -1427,7 +1427,7 @@ def request_generator():
14271427
requests (AsyncIterator[`google.pubsub_v1.types.StreamingPullRequest`]):
14281428
The request object AsyncIterator. Request for the ``StreamingPull`` streaming RPC method.
14291429
This request is used to establish the initial stream as
1430-
well as to streamacknowledgements and ack deadline
1430+
well as to streamacknowledgments and ack deadline
14311431
modifications from the client to the server.
14321432
retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
14331433
should be retried.

‎google/pubsub_v1/services/subscriber/client.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1827,7 +1827,7 @@ def streaming_pull(
18271827
metadata:Sequence[Tuple[str,Union[str,bytes]]]= (),
18281828
)->Iterable[pubsub.StreamingPullResponse]:
18291829
r"""Establishes a stream with the server, which sends messages down
1830-
to the client. The client streamsacknowledgements and ack
1830+
to the client. The client streamsacknowledgments and ack
18311831
deadline modifications back to the server. The server will close
18321832
the stream and return the status on any error. The server may
18331833
close the stream with status ``UNAVAILABLE`` to reassign
@@ -1877,7 +1877,7 @@ def request_generator():
18771877
requests (Iterator[google.pubsub_v1.types.StreamingPullRequest]):
18781878
The request object iterator. Request for the ``StreamingPull`` streaming RPC method.
18791879
This request is used to establish the initial stream as
1880-
well as to streamacknowledgements and ack deadline
1880+
well as to streamacknowledgments and ack deadline
18811881
modifications from the client to the server.
18821882
retry (google.api_core.retry.Retry): Designation of what errors, if any,
18831883
should be retried.

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -571,7 +571,7 @@ def streaming_pull(
571571
r"""Return a callable for the streaming pull method over gRPC.
572572
573573
Establishes a stream with the server, which sends messages down
574-
to the client. The client streamsacknowledgements and ack
574+
to the client. The client streamsacknowledgments and ack
575575
deadline modifications back to the server. The server will close
576576
the stream and return the status on any error. The server may
577577
close the stream with status ``UNAVAILABLE`` to reassign

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -585,7 +585,7 @@ def streaming_pull(
585585
r"""Return a callable for the streaming pull method over gRPC.
586586
587587
Establishes a stream with the server, which sends messages down
588-
to the client. The client streamsacknowledgements and ack
588+
to the client. The client streamsacknowledgments and ack
589589
deadline modifications back to the server. The server will close
590590
the stream and return the status on any error. The server may
591591
close the stream with status ``UNAVAILABLE`` to reassign

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp