Skip to content

Commit 639c45d

Browse files
committed
fixed logged channel update
1 parent c17254e commit 639c45d

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -368,8 +368,8 @@ async def _manage_channel(
368368
# prepare new channel for use
369369
old_channel = self.transport.grpc_channel
370370
new_channel = self.transport.create_channel()
371+
new_channel._unary_unary_interceptors.append(self.transport._interceptor)
371372
await self._ping_and_warm_instances(channel=new_channel)
372-
new_channel.unary_unary_interceptors.append(self.transport._interceptor)
373373
# cycle channel out of use, with long grace window before closure
374374
# TODO: refactor to avoid using internal references: https://github.com/googleapis/python-bigtable/issues/1094
375375
self.transport._grpc_channel = new_channel

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,8 +282,10 @@ def _manage_channel(
282282
start_timestamp = time.monotonic()
283283
old_channel = self.transport.grpc_channel
284284
new_channel = self.transport.create_channel()
285+
new_channel._unary_unary_interceptors.append(self.transport._interceptor)
285286
self._ping_and_warm_instances(channel=new_channel)
286287
self.transport._grpc_channel = new_channel
288+
self.transport._logged_channel = new_channel
287289
self.transport._stubs = {}
288290
self.transport._prep_wrapped_messages(self.client_info)
289291
if grace_period:

0 commit comments

Comments
 (0)