reduce logs

83c5285a8073002dcca82db7d7e284ba749b9608 · 2026-01-16 13:52:35 +0000 · Evan

previous commits logs were too verbose, this tones them down a bit

Files touched

M src/exo/worker/utils/net_profile.py

Diff

commit 83c5285a8073002dcca82db7d7e284ba749b9608
Author: Evan <evanev7@gmail.com>
Date:   Fri Jan 16 13:52:35 2026 +0000

    reduce logs
    
    previous commits logs were too verbose, this tones them down a bit
---
 src/exo/worker/utils/net_profile.py | 29 ++++++++++++++---------------
 1 file changed, 14 insertions(+), 15 deletions(-)

diff --git a/src/exo/worker/utils/net_profile.py b/src/exo/worker/utils/net_profile.py
index 7a0772ca..18887562 100644
--- a/src/exo/worker/utils/net_profile.py
+++ b/src/exo/worker/utils/net_profile.py
@@ -22,7 +22,6 @@ async def check_reachability(
     url = f"http://{target_ip}:52415/node_id"
 
     remote_node_id = None
-
     last_error = None
 
     for _ in range(REACHABILITY_ATTEMPTS):
@@ -40,24 +39,24 @@ async def check_reachability(
             remote_node_id = NodeId(body)
             break
 
+        # expected failure cases
         except (
-            httpx.ConnectError,
-            httpx.ConnectTimeout,
-            httpx.ReadTimeout,
-            httpx.RemoteProtocolError,
-        ) as e:
+            httpx.TimeoutException,
+            httpx.NetworkError,
+        ):
+            await anyio.sleep(1)
+
+        # other failures should be logged on last attempt
+        except httpx.HTTPError as e:
             last_error = e
             await anyio.sleep(1)
 
-    else:
-        if last_error is not None:
-            logger.warning(
-                f"connect error {type(last_error).__name__} from {target_ip} after {REACHABILITY_ATTEMPTS} attempts; treating as down"
-            )
-        else:
-            logger.warning(
-                f"malformed response from {target_ip} after {REACHABILITY_ATTEMPTS} attempts; treating as down"
-            )
+    if last_error is not None:
+        logger.warning(
+            f"connect error {type(last_error).__name__} from {target_ip} after {REACHABILITY_ATTEMPTS} attempts; treating as down"
+        )
+
+    if remote_node_id is None:
         return
 
     if remote_node_id != expected_node_id:

← 39ee2bf7 switch from synchronous threaded pinging to an async impleme · back to Exo · Add GitHub releases with Sparkle release notes integration ( 07cf2c1a →