alihan/exo
1
0
Fork 0
mirror of https://github.com/exo-explore/exo.git synced 2025-10-23 02:57:14 +03:00
Code Issues Packages Projects Releases Wiki Activity

handle intermediate state for when config is being updated

Browse Source
This commit is contained in:
Ian Paul
2024-10-24 09:16:46 +07:00
parent 98118babae
commit 2e8227fccb
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
exo/networking/manual/manual_discovery.py
View File

@@ -101,15 +101,17 @@ class ManualDiscovery(Discovery):
f"Current known peers: {[peer.id() for peer in self.known_peers.values()]}"
)
def _get_peers(self):
def _get_peers(self):
try:
topology = NetworkTopology.from_path(self.network_config_path)
if self.node_id not in topology.peers:
raise ValueError(
f"Node ID {self.node_id} not found in network config file {self.network_config_path}. Please run with `node_id` set to one of the keys in the config file: {[k for k, _ in topology.peers]}"
)
raise ValueError(f"Node ID {self.node_id} not found in network config file {self.network_config_path}. Please run with `node_id` set to one of the keys in the config file: {[k for k, _ in topology.peers]}")
peers_in_network: Dict[str, PeerConfig] = topology.peers
peers_in_network.pop(self.node_id)
except Exception as e:
if DEBUG_DISCOVERY >= 2: print(f"Error when loading network config file from {self.network_config_path}. Please update the config file in order to successfully discover peers. Exception: {e}")
peers_in_network = {}
return peers_in_network