Fix Heartbeat Checker in KV Manager Disaggregation (#31584)
Co-authored-by: Muhammad Safiullah <muhammadsafiullah136@gmail.com>
This commit is contained in:
co-authored by
Muhammad Safiullah
parent
2c64b7782e
commit
2db21daf8d
@@ -908,9 +908,6 @@ class CommonKVManager(BaseKVManager):
|
|||||||
self.heartbeat_failures[bootstrap_addr] = (
|
self.heartbeat_failures[bootstrap_addr] = (
|
||||||
self.heartbeat_failures.get(bootstrap_addr, 0) + 1
|
self.heartbeat_failures.get(bootstrap_addr, 0) + 1
|
||||||
)
|
)
|
||||||
with self.session_pool_lock:
|
|
||||||
if bootstrap_addr in self.session_pool:
|
|
||||||
del self.session_pool[bootstrap_addr]
|
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.info(f"Attempting to reconnect to {bootstrap_addr}...")
|
logger.info(f"Attempting to reconnect to {bootstrap_addr}...")
|
||||||
self.heartbeat_failures[bootstrap_addr] = (
|
self.heartbeat_failures[bootstrap_addr] = (
|
||||||
|
|||||||
Reference in New Issue
Block a user