fix(bigtable): use dynamic request path in test helpers to support authorized views

Author: chalmerlowe

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

@@ -19,12 +19,11 @@
 import pytest
 from google.api_core import retry
 from google.api_core.exceptions import ClientError, PermissionDenied
-from google.cloud.environment_vars import BIGTABLE_EMULATOR
-from google.type import date_pb2
-
 from google.cloud.bigtable.data._cross_sync import CrossSync
 from google.cloud.bigtable.data.execute_query.metadata import SqlType
 from google.cloud.bigtable.data.read_modify_write_rules import _MAX_INCREMENT_VALUE
+from google.cloud.environment_vars import BIGTABLE_EMULATOR
+from google.type import date_pb2
 
 from . import TEST_AGGREGATE_FAMILY, TEST_FAMILY, TEST_FAMILY_2, SystemTestRunner
 
@@ -68,7 +67,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 +87,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": [
                 {

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

@@ -22,15 +22,14 @@
 import pytest
 from google.api_core import retry
 from google.api_core.exceptions import ClientError, PermissionDenied
-from google.cloud.environment_vars import BIGTABLE_EMULATOR
-from google.type import date_pb2
-
 from google.cloud.bigtable.data._cross_sync import CrossSync
 from google.cloud.bigtable.data.execute_query.metadata import SqlType
 from google.cloud.bigtable.data.read_modify_write_rules import _MAX_INCREMENT_VALUE
 from google.cloud.bigtable_v2.services.bigtable.transports.grpc import (
     _LoggingClientInterceptor as GapicInterceptor,
 )
+from google.cloud.environment_vars import BIGTABLE_EMULATOR
+from google.type import date_pb2
 
 from . import TEST_AGGREGATE_FAMILY, TEST_FAMILY, TEST_FAMILY_2, SystemTestRunner
 
@@ -57,7 +56,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 +75,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": [
                 {