diff --git a/exo/orchestration/node.py b/exo/orchestration/node.py index f54744b9b..c23ac9aed 100644 --- a/exo/orchestration/node.py +++ b/exo/orchestration/node.py @@ -541,8 +541,8 @@ async def periodic_topology_collection(self, interval: int): try: did_peers_change = await self.update_peers() if DEBUG >= 2: print(f"{did_peers_change=}") - await self.collect_topology(set()) if did_peers_change: + await self.collect_topology(set()) await self.select_best_inference_engine() except Exception as e: print(f"Error collecting topology: {e}")