We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f0ff168 commit e4d60a8Copy full SHA for e4d60a8
google/cloud/bigtable/data/_async/client.py
@@ -480,7 +480,9 @@ async def _manage_channel(
480
old_channel = super_channel.swap_channel(new_channel)
481
self._invalidate_channel_stubs()
482
# give old_channel a chance to complete existing rpcs
483
- await CrossSync.event_wait(self._is_closed, grace_period, async_break_early=False)
+ await CrossSync.event_wait(
484
+ self._is_closed, grace_period, async_break_early=False
485
+ )
486
await old_channel.close()
487
# subtract the time spent waiting for the channel to be replaced
488
next_refresh = random.uniform(refresh_interval_min, refresh_interval_max)
0 commit comments