fix: add feature flag for improved mutate rows throttling (#862)

* docs: Minor formatting chore: Update gapic-generator-python to v1.11.5 build: Update rules_python to 0.24.0 PiperOrigin-RevId: 563436317 Source-Link: googleapis/googleapis@42fd37b Source-Link: googleapis/googleapis-gen@280264c Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMjgwMjY0Y2EwMmZiOTMxNmI0MjM3YTk2ZDBhZjFhMjM0M2E4MWE1NiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * fix: add feature flag for improved mutate rows throttling PiperOrigin-RevId: 565090488 Source-Link: googleapis/googleapis@e8a136f Source-Link: googleapis/googleapis-gen@9a8dcca Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOWE4ZGNjYTBmYjIxMTc2MjhhMWE2YTZjMzYyNWE2YWEzMmZjMmY3NSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Anthonios Partheniou <[email protected]>
googleapis · Sep 20, 2023 · e5af359 · e5af359
1 parent 09f8a46
commit e5af359
Show file tree

Hide file tree

Showing 22 changed files with 116 additions and 101 deletions.
diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/async_client.py b/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/async_client.py
@@ -1883,8 +1883,8 @@ async def get_iam_policy(
                 The request object. Request message for ``GetIamPolicy`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy is being requested.
-                See the operation documentation for the
+                policy is being requested. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2001,8 +2001,8 @@ async def set_iam_policy(
                 The request object. Request message for ``SetIamPolicy`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy is being specified.
-                See the operation documentation for the
+                policy is being specified. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2110,8 +2110,8 @@ async def test_iam_permissions(
                 The request object. Request message for ``TestIamPermissions`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy detail is being requested.
-                See the operation documentation for the
+                policy detail is being requested. See
+                the operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/client.py b/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/client.py
@@ -2107,8 +2107,8 @@ def get_iam_policy(
                 The request object. Request message for ``GetIamPolicy`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy is being requested.
-                See the operation documentation for the
+                policy is being requested. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2212,8 +2212,8 @@ def set_iam_policy(
                 The request object. Request message for ``SetIamPolicy`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy is being specified.
-                See the operation documentation for the
+                policy is being specified. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2318,8 +2318,8 @@ def test_iam_permissions(
                 The request object. Request message for ``TestIamPermissions`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy detail is being requested.
-                See the operation documentation for the
+                policy detail is being requested. See
+                the operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/rest.py b/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/rest.py
@@ -44,8 +44,8 @@
 from google.cloud.bigtable_admin_v2.types import instance
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
+from google.longrunning import operations_pb2  # type: ignore
 
 from .base import (
     BigtableInstanceAdminTransport,

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/async_client.py b/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/async_client.py
@@ -358,6 +358,7 @@ async def create_table_from_snapshot(
         r"""Creates a new table from the specified snapshot. The
         target table must not exist. The snapshot and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -1293,6 +1294,7 @@ async def snapshot_table(
         r"""Creates a new snapshot in the specified cluster from
         the specified source table. The cluster and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -1469,6 +1471,7 @@ async def get_snapshot(
                 time. A snapshot can be used as a
                 checkpoint for data restoration or a
                 data source for a new table.
+
                 Note: This is a private alpha release of
                 Cloud Bigtable snapshots. This feature
                 is not currently available to most Cloud
@@ -1668,6 +1671,7 @@ async def delete_snapshot(
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> None:
         r"""Permanently deletes the specified snapshot.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -2435,8 +2439,8 @@ async def get_iam_policy(
                 The request object. Request message for ``GetIamPolicy`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy is being requested.
-                See the operation documentation for the
+                policy is being requested. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2553,8 +2557,8 @@ async def set_iam_policy(
                 The request object. Request message for ``SetIamPolicy`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy is being specified.
-                See the operation documentation for the
+                policy is being specified. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2662,8 +2666,8 @@ async def test_iam_permissions(
                 The request object. Request message for ``TestIamPermissions`` method.
             resource (:class:`str`):
                 REQUIRED: The resource for which the
-                policy detail is being requested.
-                See the operation documentation for the
+                policy detail is being requested. See
+                the operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/client.py b/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/client.py
@@ -685,6 +685,7 @@ def create_table_from_snapshot(
         r"""Creates a new table from the specified snapshot. The
         target table must not exist. The snapshot and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -1587,6 +1588,7 @@ def snapshot_table(
         r"""Creates a new snapshot in the specified cluster from
         the specified source table. The cluster and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -1763,6 +1765,7 @@ def get_snapshot(
                 time. A snapshot can be used as a
                 checkpoint for data restoration or a
                 data source for a new table.
+
                 Note: This is a private alpha release of
                 Cloud Bigtable snapshots. This feature
                 is not currently available to most Cloud
@@ -1942,6 +1945,7 @@ def delete_snapshot(
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> None:
         r"""Permanently deletes the specified snapshot.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -2690,8 +2694,8 @@ def get_iam_policy(
                 The request object. Request message for ``GetIamPolicy`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy is being requested.
-                See the operation documentation for the
+                policy is being requested. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2795,8 +2799,8 @@ def set_iam_policy(
                 The request object. Request message for ``SetIamPolicy`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy is being specified.
-                See the operation documentation for the
+                policy is being specified. See the
+                operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field
@@ -2901,8 +2905,8 @@ def test_iam_permissions(
                 The request object. Request message for ``TestIamPermissions`` method.
             resource (str):
                 REQUIRED: The resource for which the
-                policy detail is being requested.
-                See the operation documentation for the
+                policy detail is being requested. See
+                the operation documentation for the
                 appropriate value for this field.
 
                 This corresponds to the ``resource`` field

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc.py b/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc.py
@@ -294,6 +294,7 @@ def create_table_from_snapshot(
         Creates a new table from the specified snapshot. The
         target table must not exist. The snapshot and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -591,6 +592,7 @@ def snapshot_table(
         Creates a new snapshot in the specified cluster from
         the specified source table. The cluster and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -692,6 +694,7 @@ def delete_snapshot(
         r"""Return a callable for the delete snapshot method over gRPC.
 
         Permanently deletes the specified snapshot.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc_asyncio.py b/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc_asyncio.py
@@ -302,6 +302,7 @@ def create_table_from_snapshot(
         Creates a new table from the specified snapshot. The
         target table must not exist. The snapshot and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -607,6 +608,7 @@ def snapshot_table(
         Creates a new snapshot in the specified cluster from
         the specified source table. The cluster and the table
         must be in the same instance.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be
@@ -710,6 +712,7 @@ def delete_snapshot(
         r"""Return a callable for the delete snapshot method over gRPC.
 
         Permanently deletes the specified snapshot.
+
         Note: This is a private alpha release of Cloud Bigtable
         snapshots. This feature is not currently available to
         most Cloud Bigtable customers. This feature might be

diff --git a/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/rest.py b/google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/rest.py
@@ -45,8 +45,8 @@
 from google.cloud.bigtable_admin_v2.types import table as gba_table
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
+from google.longrunning import operations_pb2  # type: ignore
 
 from .base import (
     BigtableTableAdminTransport,
@@ -2172,6 +2172,7 @@ def __call__(
                 time. A snapshot can be used as a
                 checkpoint for data restoration or a
                 data source for a new table.
+
                 Note: This is a private alpha release of
                 Cloud Bigtable snapshots. This feature
                 is not currently available to most Cloud

diff --git a/google/cloud/bigtable_admin_v2/types/bigtable_table_admin.py b/google/cloud/bigtable_admin_v2/types/bigtable_table_admin.py
@@ -918,6 +918,7 @@ class DeleteSnapshotRequest(proto.Message):
 
 class SnapshotTableMetadata(proto.Message):
     r"""The metadata for the Operation returned by SnapshotTable.
+
     Note: This is a private alpha release of Cloud Bigtable
     snapshots. This feature is not currently available to most Cloud
     Bigtable customers. This feature might be changed in

diff --git a/google/cloud/bigtable_admin_v2/types/instance.py b/google/cloud/bigtable_admin_v2/types/instance.py
@@ -117,8 +117,8 @@ class Type(proto.Enum):
                 be set on the cluster.
             DEVELOPMENT (2):
                 DEPRECATED: Prefer PRODUCTION for all use
-                cases, as it no longer enforces
-                a higher minimum node count than DEVELOPMENT.
+                cases, as it no longer enforces a higher minimum
+                node count than DEVELOPMENT.
         """
         TYPE_UNSPECIFIED = 0
         PRODUCTION = 1

diff --git a/google/cloud/bigtable_admin_v2/types/table.py b/google/cloud/bigtable_admin_v2/types/table.py
@@ -311,6 +311,7 @@ class ColumnFamily(proto.Message):
         gc_rule (google.cloud.bigtable_admin_v2.types.GcRule):
             Garbage collection rule specified as a
             protobuf. Must serialize to at most 500 bytes.
+
             NOTE: Garbage collection executes
             opportunistically in the background, and so it's
             possible for reads to return a cell even if it
@@ -481,6 +482,7 @@ class Snapshot(proto.Message):
     r"""A snapshot of a table at a particular time. A snapshot can be
     used as a checkpoint for data restoration or a data source for a
     new table.
+
     Note: This is a private alpha release of Cloud Bigtable
     snapshots. This feature is not currently available to most Cloud
     Bigtable customers. This feature might be changed in

diff --git a/google/cloud/bigtable_v2/services/bigtable/async_client.py b/google/cloud/bigtable_v2/services/bigtable/async_client.py
@@ -1030,8 +1030,8 @@ def generate_initial_change_stream_partitions(
         Args:
             request (Optional[Union[google.cloud.bigtable_v2.types.GenerateInitialChangeStreamPartitionsRequest, dict]]):
                 The request object. NOTE: This API is intended to be used
-                by Apache Beam BigtableIO.
-                Request message for
+                by Apache Beam BigtableIO. Request
+                message for
                 Bigtable.GenerateInitialChangeStreamPartitions.
             table_name (:class:`str`):
                 Required. The unique name of the table from which to get
@@ -1061,8 +1061,8 @@ def generate_initial_change_stream_partitions(
         Returns:
             AsyncIterable[google.cloud.bigtable_v2.types.GenerateInitialChangeStreamPartitionsResponse]:
                 NOTE: This API is intended to be used
-                by Apache Beam BigtableIO.
-                Response message for
+                by Apache Beam BigtableIO. Response
+                message for
                 Bigtable.GenerateInitialChangeStreamPartitions.
 
         """
@@ -1123,17 +1123,15 @@ def read_change_stream(
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> 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.
+        BigtableIO. Reads changes from a table's change stream.
+        Changes will reflect both user-initiated mutations and
+        mutations that are caused by garbage collection.
 
         Args:
             request (Optional[Union[google.cloud.bigtable_v2.types.ReadChangeStreamRequest, dict]]):
                 The request object. NOTE: This API is intended to be used
-                by Apache Beam BigtableIO.
-                Request message for
-                Bigtable.ReadChangeStream.
+                by Apache Beam BigtableIO. Request
+                message for Bigtable.ReadChangeStream.
             table_name (:class:`str`):
                 Required. The unique name of the table from which to
                 read a change stream. Values are of the form
@@ -1162,9 +1160,8 @@ def read_change_stream(
         Returns:
             AsyncIterable[google.cloud.bigtable_v2.types.ReadChangeStreamResponse]:
                 NOTE: This API is intended to be used
-                by Apache Beam BigtableIO.
-                Response message for
-                Bigtable.ReadChangeStream.
+                by Apache Beam BigtableIO. Response
+                message for Bigtable.ReadChangeStream.
 
         """
         # Create or coerce a protobuf request object.