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.