chore: regenerate google-cloud-bigtable (#17722)

This PR also includes the fixes from
#17707

Closes #17719
Closes #17707
Fixes #17709

---------

Co-authored-by: chalmer lowe <chalmerlowe@google.com>

Author: parthea

librarian.yaml

@@ -635,7 +635,6 @@ libraries:
     apis:
       - path: google/bigtable/v2
       - path: google/bigtable/admin/v2
-    skip_generate: true
     python:
       library_type: GAPIC_COMBO
       opt_args_by_api:

packages/google-cloud-bigtable/mypy.ini

@@ -0,0 +1,12 @@
+# We use the constraints file for the latest Python version
+# (currently this file) to check that the latest
+# major versions of dependencies are supported in setup.py.
+# List all library dependencies and extras in this file.
+# Require the latest major version be installed for each dependency.
+# e.g., if setup.py has "google-cloud-foo >= 1.14.0, < 2.0.0",
+# Then this file should have google-cloud-foo>=1
+google-api-core>=2
+google-auth>=2
+grpcio>=1
+proto-plus>=1
+protobuf>=7

packages/google-cloud-bigtable/testing/constraints-3.15.txt

@@ -68,7 +68,7 @@ async def add_row(
         elif isinstance(value, int):
             value = value.to_bytes(8, byteorder="big", signed=True)
         request = {
-            "table_name": self.target.table_name,
+            **self.target._request_path,
             "row_key": row_key,
             "mutations": [
                 {
@@ -88,7 +88,7 @@ async def add_aggregate_row(
         self, row_key, *, family=TEST_AGGREGATE_FAMILY, qualifier=b"q", input=0
     ):
         request = {
-            "table_name": self.target.table_name,
+            **self.target._request_path,
             "row_key": row_key,
             "mutations": [
                 {
@@ -107,14 +107,44 @@ async def add_aggregate_row(
     @CrossSync.convert
     async def delete_rows(self):
         if self.rows:
-            request = {
-                "table_name": self.target.table_name,
-                "entries": [
-                    {"row_key": row, "mutations": [{"delete_from_row": {}}]}
-                    for row in self.rows
-                ],
-            }
-            await self.target.client._gapic_client.mutate_rows(request)
+            # Chunk deletions to 5,000 rows. While Bigtable officially supports up to
+            # 100,000 mutations per MutateRows RPC, sending massive batches may hit
+            # the default gRPC 4MB client payload size limit due to metadata
+            # serialization overhead. Keeping chunks at 5,000 ensures we stay safely
+            # under 4MB and minimizes transient network timeouts on live connections.
+            chunk_size = 5000
+            rows_list = list(self.rows)
+
+            # Check if the test target is an Authorized View
+            is_authorized_view = "authorized_view_name" in self.target._request_path
+
+            if is_authorized_view:
+                # For Authorized Views, we cannot use delete_from_row because it attempts
+                # to delete families outside the view's scope. We must delete explicitly
+                # from the allowed families we wrote to.
+                mutations = [
+                    {"delete_from_family": {"family_name": TEST_FAMILY}},
+                    {"delete_from_family": {"family_name": TEST_AGGREGATE_FAMILY}},
+                ]
+            else:
+                mutations = [{"delete_from_row": {}}]
+
+            for i in range(0, len(rows_list), chunk_size):
+                chunk = rows_list[i : i + chunk_size]
+                request = {
+                    **self.target._request_path,
+                    "entries": [
+                        {"row_key": row, "mutations": mutations} for row in chunk
+                    ],
+                }
+                # Await and consume the gRPC stream to guarantee execution
+                stream = await self.target.client._gapic_client.mutate_rows(request)
+                async for response in stream:
+                    for entry in response.entries:
+                        if entry.status.code != 0:
+                            raise RuntimeError(
+                                f"Failed to delete row: {entry.status.message}"
+                            )
 
     @CrossSync.convert
     async def retrieve_cell_value(self, target, row_key):

packages/google-cloud-bigtable/tests/system/data/test_system_async.py

@@ -57,7 +57,7 @@ def add_row(
         elif isinstance(value, int):
             value = value.to_bytes(8, byteorder="big", signed=True)
         request = {
-            "table_name": self.target.table_name,
+            **self.target._request_path,
             "row_key": row_key,
             "mutations": [
                 {
@@ -76,7 +76,7 @@ def add_aggregate_row(
         self, row_key, *, family=TEST_AGGREGATE_FAMILY, qualifier=b"q", input=0
     ):
         request = {
-            "table_name": self.target.table_name,
+            **self.target._request_path,
             "row_key": row_key,
             "mutations": [
                 {
@@ -94,14 +94,31 @@ def add_aggregate_row(
 
     def delete_rows(self):
         if self.rows:
-            request = {
-                "table_name": self.target.table_name,
-                "entries": [
-                    {"row_key": row, "mutations": [{"delete_from_row": {}}]}
-                    for row in self.rows
-                ],
-            }
-            self.target.client._gapic_client.mutate_rows(request)
+            chunk_size = 5000
+            rows_list = list(self.rows)
+            is_authorized_view = "authorized_view_name" in self.target._request_path
+            if is_authorized_view:
+                mutations = [
+                    {"delete_from_family": {"family_name": TEST_FAMILY}},
+                    {"delete_from_family": {"family_name": TEST_AGGREGATE_FAMILY}},
+                ]
+            else:
+                mutations = [{"delete_from_row": {}}]
+            for i in range(0, len(rows_list), chunk_size):
+                chunk = rows_list[i : i + chunk_size]
+                request = {
+                    **self.target._request_path,
+                    "entries": [
+                        {"row_key": row, "mutations": mutations} for row in chunk
+                    ],
+                }
+                stream = self.target.client._gapic_client.mutate_rows(request)
+                for response in stream:
+                    for entry in response.entries:
+                        if entry.status.code != 0:
+                            raise RuntimeError(
+                                f"Failed to delete row: {entry.status.message}"
+                            )
 
     def retrieve_cell_value(self, target, row_key):
         """Helper to read an individual row"""

packages/google-cloud-bigtable/tests/system/data/test_system_autogen.py

@@ -2998,15 +2998,11 @@ def test_execute_query_with_params(self, client, execute_query_mock, prepare_moc
     def test_execute_query_with_view_parameters(
         self, client, execute_query_mock, prepare_mock
     ):
-        values = [
-            *chunked_responses(2, str_val("test2"), int_val(9), token=b"r2"),
-        ]
+        values = [*chunked_responses(2, str_val("test2"), int_val(9), token=b"r2")]
         execute_query_mock.return_value = self._make_gapic_stream(values)
         query_str = f"SELECT a, b FROM {self.TABLE_NAME} WHERE user_id = VIEW_PARAMETERS('user_id')"
         result = client.execute_query(
-            query_str,
-            self.INSTANCE_NAME,
-            view_parameters={"user_id": "alice"},
+            query_str, self.INSTANCE_NAME, view_parameters={"user_id": "alice"}
         )
         results = [r for r in result]
         assert len(results) == 1
@@ -3015,7 +3011,6 @@ def test_execute_query_with_view_parameters(
         assert execute_query_mock.call_count == 1
         assert prepare_mock.call_count == 1
         assert prepare_mock.call_args[1]["request"]["query"] == query_str
-
         request = execute_query_mock.call_args[0][0]
         assert "user_id" in request.view_parameters
         assert request.view_parameters["user_id"].string_value == "alice"

packages/google-cloud-bigtable/tests/unit/data/_sync_autogen/test_client.py

@@ -6414,6 +6414,9 @@ def test_list_app_profiles_pager(transport_name: str = "grpc"):
         assert pager._retry == retry
         assert pager._timeout == timeout
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.AppProfile) for i in results)
@@ -6506,6 +6509,8 @@ async def test_list_app_profiles_async_pager():
             request={},
         )
         assert async_pager.next_page_token == "abc"
+        assert str(async_pager).startswith(f"{async_pager.__class__.__name__}<")
+
         responses = []
         async for response in async_pager:  # pragma: no branch
             responses.append(response)
@@ -8686,6 +8691,9 @@ def test_list_hot_tablets_pager(transport_name: str = "grpc"):
         assert pager._retry == retry
         assert pager._timeout == timeout
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.HotTablet) for i in results)
@@ -8774,6 +8782,8 @@ async def test_list_hot_tablets_async_pager():
             request={},
         )
         assert async_pager.next_page_token == "abc"
+        assert str(async_pager).startswith(f"{async_pager.__class__.__name__}<")
+
         responses = []
         async for response in async_pager:  # pragma: no branch
             responses.append(response)
@@ -9928,6 +9938,9 @@ def test_list_logical_views_pager(transport_name: str = "grpc"):
         assert pager._retry == retry
         assert pager._timeout == timeout
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.LogicalView) for i in results)
@@ -10020,6 +10033,8 @@ async def test_list_logical_views_async_pager():
             request={},
         )
         assert async_pager.next_page_token == "abc"
+        assert str(async_pager).startswith(f"{async_pager.__class__.__name__}<")
+
         responses = []
         async for response in async_pager:  # pragma: no branch
             responses.append(response)
@@ -11885,6 +11900,9 @@ def test_list_materialized_views_pager(transport_name: str = "grpc"):
         assert pager._retry == retry
         assert pager._timeout == timeout
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.MaterializedView) for i in results)
@@ -11977,6 +11995,8 @@ async def test_list_materialized_views_async_pager():
             request={},
         )
         assert async_pager.next_page_token == "abc"
+        assert str(async_pager).startswith(f"{async_pager.__class__.__name__}<")
+
         responses = []
         async for response in async_pager:  # pragma: no branch
             responses.append(response)
@@ -15370,6 +15390,9 @@ def test_list_app_profiles_rest_pager(transport: str = "rest"):
 
         pager = client.list_app_profiles(request=sample_request)
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.AppProfile) for i in results)
@@ -16596,6 +16619,9 @@ def test_list_hot_tablets_rest_pager(transport: str = "rest"):
 
         pager = client.list_hot_tablets(request=sample_request)
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.HotTablet) for i in results)
@@ -17251,6 +17277,9 @@ def test_list_logical_views_rest_pager(transport: str = "rest"):
 
         pager = client.list_logical_views(request=sample_request)
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.LogicalView) for i in results)
@@ -18281,6 +18310,9 @@ def test_list_materialized_views_rest_pager(transport: str = "rest"):
 
         pager = client.list_materialized_views(request=sample_request)
 
+        assert pager.next_page_token == "abc"
+        assert str(pager).startswith(f"{pager.__class__.__name__}<")
+
         results = list(pager)
         assert len(results) == 6
         assert all(isinstance(i, instance.MaterializedView) for i in results)