chore: update gapic

google/cloud/bigtable/data/_async/client.py

@@ -87,6 +87,7 @@
 else:
     from typing import Iterable  # noqa: F401
     from grpc import insecure_channel
+    from grpc import intercept_channel
     from google.cloud.bigtable_v2.services.bigtable.transports import BigtableGrpcTransport as TransportType  # type: ignore
     from google.cloud.bigtable.data._sync_autogen.mutations_batcher import _MB_SIZE
 
@@ -366,11 +367,21 @@ async def _manage_channel(
                 break
             start_timestamp = time.monotonic()
             # prepare new channel for use
+            # TODO: refactor to avoid using internal references: https://github.com/googleapis/python-bigtable/issues/1094
             old_channel = self.transport.grpc_channel
             new_channel = self.transport.create_channel()
+            if CrossSync.is_async:
+                new_channel._unary_unary_interceptors.append(
+                    self.transport._interceptor
+                )
+            else:
+                new_channel = intercept_channel(
+                    new_channel, self.transport._interceptor
+                )
             await self._ping_and_warm_instances(channel=new_channel)
             # cycle channel out of use, with long grace window before closure
             self.transport._grpc_channel = new_channel
+            self.transport._logged_channel = new_channel
             # invalidate caches
             self.transport._stubs = {}
             self.transport._prep_wrapped_messages(self.client_info)

google/cloud/bigtable/data/_sync_autogen/client.py

@@ -66,6 +66,7 @@
 from google.cloud.bigtable.data._cross_sync import CrossSync
 from typing import Iterable
 from grpc import insecure_channel
+from grpc import intercept_channel
 from google.cloud.bigtable_v2.services.bigtable.transports import (
     BigtableGrpcTransport as TransportType,
 )
@@ -282,8 +283,10 @@ def _manage_channel(
             start_timestamp = time.monotonic()
             old_channel = self.transport.grpc_channel
             new_channel = self.transport.create_channel()
+            new_channel = intercept_channel(new_channel, self.transport._interceptor)
             self._ping_and_warm_instances(channel=new_channel)
             self.transport._grpc_channel = new_channel
+            self.transport._logged_channel = new_channel
             self.transport._stubs = {}
             self.transport._prep_wrapped_messages(self.client_info)
             if grace_period:

google/cloud/bigtable_admin/__init__.py

@@ -46,6 +46,18 @@
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     CreateInstanceRequest,
 )
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    CreateLogicalViewMetadata,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    CreateLogicalViewRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    CreateMaterializedViewMetadata,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    CreateMaterializedViewRequest,
+)
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     DeleteAppProfileRequest,
 )
@@ -55,6 +67,12 @@
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     DeleteInstanceRequest,
 )
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    DeleteLogicalViewRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    DeleteMaterializedViewRequest,
+)
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     GetAppProfileRequest,
 )
@@ -64,6 +82,12 @@
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     GetInstanceRequest,
 )
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    GetLogicalViewRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    GetMaterializedViewRequest,
+)
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     ListAppProfilesRequest,
 )
@@ -88,6 +112,18 @@
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     ListInstancesResponse,
 )
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    ListLogicalViewsRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    ListLogicalViewsResponse,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    ListMaterializedViewsRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    ListMaterializedViewsResponse,
+)
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     PartialUpdateClusterMetadata,
 )
@@ -109,6 +145,18 @@
 from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
     UpdateInstanceMetadata,
 )
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    UpdateLogicalViewMetadata,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    UpdateLogicalViewRequest,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    UpdateMaterializedViewMetadata,
+)
+from google.cloud.bigtable_admin_v2.types.bigtable_instance_admin import (
+    UpdateMaterializedViewRequest,
+)
 from google.cloud.bigtable_admin_v2.types.bigtable_table_admin import (
     CheckConsistencyRequest,
 )
@@ -230,6 +278,8 @@
 from google.cloud.bigtable_admin_v2.types.instance import Cluster
 from google.cloud.bigtable_admin_v2.types.instance import HotTablet
 from google.cloud.bigtable_admin_v2.types.instance import Instance
+from google.cloud.bigtable_admin_v2.types.instance import LogicalView
+from google.cloud.bigtable_admin_v2.types.instance import MaterializedView
 from google.cloud.bigtable_admin_v2.types.table import AuthorizedView
 from google.cloud.bigtable_admin_v2.types.table import Backup
 from google.cloud.bigtable_admin_v2.types.table import BackupInfo
@@ -253,12 +303,20 @@
     "CreateClusterRequest",
     "CreateInstanceMetadata",
     "CreateInstanceRequest",
+    "CreateLogicalViewMetadata",
+    "CreateLogicalViewRequest",
+    "CreateMaterializedViewMetadata",
+    "CreateMaterializedViewRequest",
     "DeleteAppProfileRequest",
     "DeleteClusterRequest",
     "DeleteInstanceRequest",
+    "DeleteLogicalViewRequest",
+    "DeleteMaterializedViewRequest",
     "GetAppProfileRequest",
     "GetClusterRequest",
     "GetInstanceRequest",
+    "GetLogicalViewRequest",
+    "GetMaterializedViewRequest",
     "ListAppProfilesRequest",
     "ListAppProfilesResponse",
     "ListClustersRequest",
@@ -267,13 +325,21 @@
     "ListHotTabletsResponse",
     "ListInstancesRequest",
     "ListInstancesResponse",
+    "ListLogicalViewsRequest",
+    "ListLogicalViewsResponse",
+    "ListMaterializedViewsRequest",
+    "ListMaterializedViewsResponse",
     "PartialUpdateClusterMetadata",
     "PartialUpdateClusterRequest",
     "PartialUpdateInstanceRequest",
     "UpdateAppProfileMetadata",
     "UpdateAppProfileRequest",
     "UpdateClusterMetadata",
     "UpdateInstanceMetadata",
+    "UpdateLogicalViewMetadata",
+    "UpdateLogicalViewRequest",
+    "UpdateMaterializedViewMetadata",
+    "UpdateMaterializedViewRequest",
     "CheckConsistencyRequest",
     "CheckConsistencyResponse",
     "CopyBackupMetadata",
@@ -327,6 +393,8 @@
     "Cluster",
     "HotTablet",
     "Instance",
+    "LogicalView",
+    "MaterializedView",
     "AuthorizedView",
     "Backup",
     "BackupInfo",

google/cloud/bigtable_admin_v2/__init__.py

@@ -28,12 +28,20 @@
 from .types.bigtable_instance_admin import CreateClusterRequest
 from .types.bigtable_instance_admin import CreateInstanceMetadata
 from .types.bigtable_instance_admin import CreateInstanceRequest
+from .types.bigtable_instance_admin import CreateLogicalViewMetadata
+from .types.bigtable_instance_admin import CreateLogicalViewRequest
+from .types.bigtable_instance_admin import CreateMaterializedViewMetadata
+from .types.bigtable_instance_admin import CreateMaterializedViewRequest
 from .types.bigtable_instance_admin import DeleteAppProfileRequest
 from .types.bigtable_instance_admin import DeleteClusterRequest
 from .types.bigtable_instance_admin import DeleteInstanceRequest
+from .types.bigtable_instance_admin import DeleteLogicalViewRequest
+from .types.bigtable_instance_admin import DeleteMaterializedViewRequest
 from .types.bigtable_instance_admin import GetAppProfileRequest
 from .types.bigtable_instance_admin import GetClusterRequest
 from .types.bigtable_instance_admin import GetInstanceRequest
+from .types.bigtable_instance_admin import GetLogicalViewRequest
+from .types.bigtable_instance_admin import GetMaterializedViewRequest
 from .types.bigtable_instance_admin import ListAppProfilesRequest
 from .types.bigtable_instance_admin import ListAppProfilesResponse
 from .types.bigtable_instance_admin import ListClustersRequest
@@ -42,13 +50,21 @@
 from .types.bigtable_instance_admin import ListHotTabletsResponse
 from .types.bigtable_instance_admin import ListInstancesRequest
 from .types.bigtable_instance_admin import ListInstancesResponse
+from .types.bigtable_instance_admin import ListLogicalViewsRequest
+from .types.bigtable_instance_admin import ListLogicalViewsResponse
+from .types.bigtable_instance_admin import ListMaterializedViewsRequest
+from .types.bigtable_instance_admin import ListMaterializedViewsResponse
 from .types.bigtable_instance_admin import PartialUpdateClusterMetadata
 from .types.bigtable_instance_admin import PartialUpdateClusterRequest
 from .types.bigtable_instance_admin import PartialUpdateInstanceRequest
 from .types.bigtable_instance_admin import UpdateAppProfileMetadata
 from .types.bigtable_instance_admin import UpdateAppProfileRequest
 from .types.bigtable_instance_admin import UpdateClusterMetadata
 from .types.bigtable_instance_admin import UpdateInstanceMetadata
+from .types.bigtable_instance_admin import UpdateLogicalViewMetadata
+from .types.bigtable_instance_admin import UpdateLogicalViewRequest
+from .types.bigtable_instance_admin import UpdateMaterializedViewMetadata
+from .types.bigtable_instance_admin import UpdateMaterializedViewRequest
 from .types.bigtable_table_admin import CheckConsistencyRequest
 from .types.bigtable_table_admin import CheckConsistencyResponse
 from .types.bigtable_table_admin import CopyBackupMetadata
@@ -102,6 +118,8 @@
 from .types.instance import Cluster
 from .types.instance import HotTablet
 from .types.instance import Instance
+from .types.instance import LogicalView
+from .types.instance import MaterializedView
 from .types.table import AuthorizedView
 from .types.table import Backup
 from .types.table import BackupInfo
@@ -142,6 +160,10 @@
     "CreateClusterRequest",
     "CreateInstanceMetadata",
     "CreateInstanceRequest",
+    "CreateLogicalViewMetadata",
+    "CreateLogicalViewRequest",
+    "CreateMaterializedViewMetadata",
+    "CreateMaterializedViewRequest",
     "CreateTableFromSnapshotMetadata",
     "CreateTableFromSnapshotRequest",
     "CreateTableRequest",
@@ -151,6 +173,8 @@
     "DeleteBackupRequest",
     "DeleteClusterRequest",
     "DeleteInstanceRequest",
+    "DeleteLogicalViewRequest",
+    "DeleteMaterializedViewRequest",
     "DeleteSnapshotRequest",
     "DeleteTableRequest",
     "DropRowRangeRequest",
@@ -163,6 +187,8 @@
     "GetBackupRequest",
     "GetClusterRequest",
     "GetInstanceRequest",
+    "GetLogicalViewRequest",
+    "GetMaterializedViewRequest",
     "GetSnapshotRequest",
     "GetTableRequest",
     "HotTablet",
@@ -179,10 +205,16 @@
     "ListHotTabletsResponse",
     "ListInstancesRequest",
     "ListInstancesResponse",
+    "ListLogicalViewsRequest",
+    "ListLogicalViewsResponse",
+    "ListMaterializedViewsRequest",
+    "ListMaterializedViewsResponse",
     "ListSnapshotsRequest",
     "ListSnapshotsResponse",
     "ListTablesRequest",
     "ListTablesResponse",
+    "LogicalView",
+    "MaterializedView",
     "ModifyColumnFamiliesRequest",
     "OperationProgress",
     "OptimizeRestoredTableMetadata",
@@ -209,6 +241,10 @@
     "UpdateBackupRequest",
     "UpdateClusterMetadata",
     "UpdateInstanceMetadata",
+    "UpdateLogicalViewMetadata",
+    "UpdateLogicalViewRequest",
+    "UpdateMaterializedViewMetadata",
+    "UpdateMaterializedViewRequest",
     "UpdateTableMetadata",
     "UpdateTableRequest",
 )