|
@@ -167,7 +167,7 @@ class UDPDiscovery(Discovery):
|
|
|
current_time - last_seen > self.discovery_timeout:
|
|
|
peers_to_remove.append(peer_id)
|
|
|
|
|
|
- if DEBUG_DISCOVERY >= 2: print("Peer statuses:", {peer_handle.id(): f"is_connected={await peer_handle.is_connected()}, health_check={await peer_handle.health_check()}, {connected_at=}, {last_seen=}" for peer_handle, connected_at, last_seen in self.known_peers.values()})
|
|
|
+ if DEBUG_DISCOVERY >= 2: print("Peer statuses:", {peer_handle.id(): f"is_connected={await peer_handle.is_connected()}, health_check={await peer_handle.health_check()}, {connected_at=}, {last_seen=}" for peer_handle, connected_at, last_seen, last_is_healthy in self.known_peers.values()})
|
|
|
|
|
|
for peer_id in peers_to_remove:
|
|
|
if peer_id in self.known_peers: del self.known_peers[peer_id]
|