🦉 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/cloud/bigtable_v2/services/bigtable/async_client.py

@@ -1164,7 +1164,9 @@ async def read_modify_write_row(
                 transformed into writes. Entries are
                 applied in order, meaning that earlier
                 rules will affect the results of later
-                ones.
+                ones. At least one entry must be
+                specified, and there can be at most
+                100000 rules.
 
                 This corresponds to the ``rules`` field
                 on the ``request`` instance; if ``request`` is provided, this
@@ -1281,10 +1283,11 @@ def generate_initial_change_stream_partitions(
     ) -> Awaitable[
         AsyncIterable[bigtable.GenerateInitialChangeStreamPartitionsResponse]
     ]:
-        r"""NOTE: This API is intended to be used by Apache Beam BigtableIO.
-        Returns the current list of partitions that make up the table's
+        r"""Returns the current list of partitions that make up the table's
         change stream. The union of partitions will cover the entire
         keyspace. Partitions can be read with ``ReadChangeStream``.
+        NOTE: This API is only intended to be used by Apache Beam
+        BigtableIO.
 
         Args:
             request (Optional[Union[google.cloud.bigtable_v2.types.GenerateInitialChangeStreamPartitionsRequest, dict]]):
@@ -1392,10 +1395,11 @@ def read_change_stream(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> Awaitable[AsyncIterable[bigtable.ReadChangeStreamResponse]]:
-        r"""NOTE: This API is intended to be used by Apache Beam
-        BigtableIO. Reads changes from a table's change stream.
-        Changes will reflect both user-initiated mutations and
-        mutations that are caused by garbage collection.
+        r"""Reads changes from a table's change stream. Changes
+        will reflect both user-initiated mutations and mutations
+        that are caused by garbage collection.
+        NOTE: This API is only intended to be used by Apache
+        Beam BigtableIO.
 
         Args:
             request (Optional[Union[google.cloud.bigtable_v2.types.ReadChangeStreamRequest, dict]]):

google/cloud/bigtable_v2/services/bigtable/client.py

@@ -1625,7 +1625,9 @@ def read_modify_write_row(
                 transformed into writes. Entries are
                 applied in order, meaning that earlier
                 rules will affect the results of later
-                ones.
+                ones. At least one entry must be
+                specified, and there can be at most
+                100000 rules.
 
                 This corresponds to the ``rules`` field
                 on the ``request`` instance; if ``request`` is provided, this
@@ -1737,10 +1739,11 @@ def generate_initial_change_stream_partitions(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> Iterable[bigtable.GenerateInitialChangeStreamPartitionsResponse]:
-        r"""NOTE: This API is intended to be used by Apache Beam BigtableIO.
-        Returns the current list of partitions that make up the table's
+        r"""Returns the current list of partitions that make up the table's
         change stream. The union of partitions will cover the entire
         keyspace. Partitions can be read with ``ReadChangeStream``.
+        NOTE: This API is only intended to be used by Apache Beam
+        BigtableIO.
 
         Args:
             request (Union[google.cloud.bigtable_v2.types.GenerateInitialChangeStreamPartitionsRequest, dict]):
@@ -1847,10 +1850,11 @@ def read_change_stream(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> Iterable[bigtable.ReadChangeStreamResponse]:
-        r"""NOTE: This API is intended to be used by Apache Beam
-        BigtableIO. Reads changes from a table's change stream.
-        Changes will reflect both user-initiated mutations and
-        mutations that are caused by garbage collection.
+        r"""Reads changes from a table's change stream. Changes
+        will reflect both user-initiated mutations and mutations
+        that are caused by garbage collection.
+        NOTE: This API is only intended to be used by Apache
+        Beam BigtableIO.
 
         Args:
             request (Union[google.cloud.bigtable_v2.types.ReadChangeStreamRequest, dict]):

google/cloud/bigtable_v2/services/bigtable/transports/grpc.py

@@ -538,10 +538,11 @@ def generate_initial_change_stream_partitions(
         r"""Return a callable for the generate initial change stream
         partitions method over gRPC.
 
-        NOTE: This API is intended to be used by Apache Beam BigtableIO.
         Returns the current list of partitions that make up the table's
         change stream. The union of partitions will cover the entire
         keyspace. Partitions can be read with ``ReadChangeStream``.
+        NOTE: This API is only intended to be used by Apache Beam
+        BigtableIO.
 
         Returns:
             Callable[[~.GenerateInitialChangeStreamPartitionsRequest],
@@ -571,10 +572,11 @@ def read_change_stream(
     ]:
         r"""Return a callable for the read change stream method over gRPC.
 
-        NOTE: This API is intended to be used by Apache Beam
-        BigtableIO. Reads changes from a table's change stream.
-        Changes will reflect both user-initiated mutations and
-        mutations that are caused by garbage collection.
+        Reads changes from a table's change stream. Changes
+        will reflect both user-initiated mutations and mutations
+        that are caused by garbage collection.
+        NOTE: This API is only intended to be used by Apache
+        Beam BigtableIO.
 
         Returns:
             Callable[[~.ReadChangeStreamRequest],

google/cloud/bigtable_v2/services/bigtable/transports/grpc_asyncio.py

@@ -552,10 +552,11 @@ def generate_initial_change_stream_partitions(
         r"""Return a callable for the generate initial change stream
         partitions method over gRPC.
 
-        NOTE: This API is intended to be used by Apache Beam BigtableIO.
         Returns the current list of partitions that make up the table's
         change stream. The union of partitions will cover the entire
         keyspace. Partitions can be read with ``ReadChangeStream``.
+        NOTE: This API is only intended to be used by Apache Beam
+        BigtableIO.
 
         Returns:
             Callable[[~.GenerateInitialChangeStreamPartitionsRequest],
@@ -585,10 +586,11 @@ def read_change_stream(
     ]:
         r"""Return a callable for the read change stream method over gRPC.
 
-        NOTE: This API is intended to be used by Apache Beam
-        BigtableIO. Reads changes from a table's change stream.
-        Changes will reflect both user-initiated mutations and
-        mutations that are caused by garbage collection.
+        Reads changes from a table's change stream. Changes
+        will reflect both user-initiated mutations and mutations
+        that are caused by garbage collection.
+        NOTE: This API is only intended to be used by Apache
+        Beam BigtableIO.
 
         Returns:
             Callable[[~.ReadChangeStreamRequest],

google/cloud/bigtable_v2/types/bigtable.py

@@ -197,27 +197,12 @@ class ReadRowsResponse(proto.Message):
             row key, allowing the client to skip that work
             on a retry.
         request_stats (google.cloud.bigtable_v2.types.RequestStats):
-            If requested, provide enhanced query performance statistics.
-            The semantics dictate:
-
-            -  request_stats is empty on every (streamed) response,
-               except
-            -  request_stats has non-empty information after all chunks
-               have been streamed, where the ReadRowsResponse message
-               only contains request_stats.
-
-               -  For example, if a read request would have returned an
-                  empty response instead a single ReadRowsResponse is
-                  streamed with empty chunks and request_stats filled.
-
-            Visually, response messages will stream as follows: ... ->
-            {chunks: [...]} -> {chunks: [], request_stats: {...}}
-            \_\ **/ \_**\ \__________/ Primary response Trailer of
-            RequestStats info
-
-            Or if the read did not return any values: {chunks: [],
-            request_stats: {...}} \________________________________/
-            Trailer of RequestStats info
+            If requested, return enhanced query performance statistics.
+            The field request_stats is empty in a streamed response
+            unless the ReadRowsResponse message contains request_stats
+            in the last message of the stream. Always returned when
+            requested, even when the read request returns an empty
+            response.
     """
 
     class CellChunk(proto.Message):
@@ -649,8 +634,8 @@ class RateLimitInfo(proto.Message):
             ``factor`` until another ``period`` has passed.
 
             The client can measure its load using any unit that's
-            comparable over time For example, QPS can be used as long as
-            each request involves a similar amount of work.
+            comparable over time. For example, QPS can be used as long
+            as each request involves a similar amount of work.
     """
 
     period: duration_pb2.Duration = proto.Field(
@@ -816,7 +801,9 @@ class ReadModifyWriteRowRequest(proto.Message):
             row's contents are to be transformed into
             writes. Entries are applied in order, meaning
             that earlier rules will affect the results of
-            later ones.
+            later ones. At least one entry must be
+            specified, and there can be at most 100000
+            rules.
     """
 
     table_name: str = proto.Field(
@@ -944,10 +931,10 @@ class ReadChangeStreamRequest(proto.Message):
             the stream as part of ``Heartbeat`` and ``CloseStream``
             messages.
 
-            If a single token is provided, the token’s partition must
-            exactly match the request’s partition. If multiple tokens
+            If a single token is provided, the token's partition must
+            exactly match the request's partition. If multiple tokens
             are provided, as in the case of a partition merge, the union
-            of the token partitions must exactly cover the request’s
+            of the token partitions must exactly cover the request's
             partition. Otherwise, INVALID_ARGUMENT will be returned.
 
             This field is a member of `oneof`_ ``start_from``.
@@ -1128,7 +1115,7 @@ class DataChange(proto.Message):
                 a record that will be delivered in the future on
                 the stream. It is possible that, under
                 particular circumstances that a future record
-                has a timestamp is is lower than a previously
+                has a timestamp that is lower than a previously
                 seen timestamp. For an example usage see
                 https://beam.apache.org/documentation/basics/#watermarks
         """
@@ -1212,7 +1199,7 @@ class Heartbeat(proto.Message):
                 a record that will be delivered in the future on
                 the stream. It is possible that, under
                 particular circumstances that a future record
-                has a timestamp is is lower than a previously
+                has a timestamp that is lower than a previously
                 seen timestamp. For an example usage see
                 https://beam.apache.org/documentation/basics/#watermarks
         """
@@ -1235,12 +1222,25 @@ class CloseStream(proto.Message):
         if there was an ``end_time`` specified). If ``continuation_tokens``
         & ``new_partitions`` are present, then a change in partitioning
         requires the client to open a new stream for each token to resume
-        reading. Example: [B, D) ends \| v new_partitions: [A, C) [C, E)
-        continuation_tokens.partitions: [B,C) [C,D) ^---^ ^---^ ^ ^ \| \| \|
-        StreamContinuationToken 2 \| StreamContinuationToken 1 To read the
-        new partition [A,C), supply the continuation tokens whose ranges
-        cover the new partition, for example ContinuationToken[A,B) &
-        ContinuationToken[B,C).
+        reading. Example:
+
+        ::
+
+                                             [B,      D) ends
+                                                  |
+                                                  v
+                          new_partitions:  [A,  C) [C,  E)
+            continuation_tokens.partitions:  [B,C) [C,D)
+                                             ^---^ ^---^
+                                             ^     ^
+                                             |     |
+                                             |     StreamContinuationToken 2
+                                             |
+                                             StreamContinuationToken 1
+
+        To read the new partition [A,C), supply the continuation tokens
+        whose ranges cover the new partition, for example
+        ContinuationToken[A,B) & ContinuationToken[B,C).
 
         Attributes:
             status (google.rpc.status_pb2.Status):

google/cloud/bigtable_v2/types/data.py

@@ -241,7 +241,8 @@ class Value(proto.Message):
             This field is a member of `oneof`_ ``kind``.
         float_value (float):
             Represents a typed value transported as a
-            floating point number.
+            floating point number. Does not support NaN or
+            infinities.
 
             This field is a member of `oneof`_ ``kind``.
         timestamp_value (google.protobuf.timestamp_pb2.Timestamp):

google/cloud/bigtable_v2/types/request_stats.py

@@ -142,11 +142,10 @@ class FullReadStatsView(proto.Message):
 
 
 class RequestStats(proto.Message):
-    r"""RequestStats is the container for additional information pertaining
-    to a single request, helpful for evaluating the performance of the
-    sent request. Currently, there are the following supported methods:
-
-    -  google.bigtable.v2.ReadRows
+    r"""RequestStats is the container for additional information
+    pertaining to a single request, helpful for evaluating the
+    performance of the sent request. Currently, the following method
+    is supported: google.bigtable.v2.ReadRows
 
 
     .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

google/cloud/bigtable_v2/types/response_params.py

@@ -29,10 +29,7 @@
 
 
 class ResponseParams(proto.Message):
-    r"""Response metadata proto This is an experimental feature that will be
-    used to get zone_id and cluster_id from response trailers to tag the
-    metrics. This should not be used by customers directly
-
+    r"""Response metadata proto
 
     .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields