Skip to content
This repository was archived by the owner on Apr 1, 2026. It is now read-only.

Commit c4a97e1

Browse files
committed
put back in cache invalidation
1 parent 5e107fc commit c4a97e1

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -401,6 +401,9 @@ async def _manage_channel(
401401
await self._ping_and_warm_instances(channel=new_sub_channel)
402402
# cycle channel out of use, with long grace window before closure
403403
await channel.replace_wrapped_channel(new_sub_channel, grace_period)
404+
# invalidate caches
405+
self.transport._stubs = {}
406+
self.transport._prep_wrapped_messages(self.client_info)
404407
# subtract the time spent waiting for the channel to be replaced
405408
next_refresh = random.uniform(refresh_interval_min, refresh_interval_max)
406409
next_sleep = max(next_refresh - (time.monotonic() - start_timestamp), 0)

0 commit comments

Comments
 (0)