less aggressive logs for opaque status / download progress. too much spam

41dd700ff4315845ae0539be75596bd5f5ed9dd8 · 2024-09-04 17:25:43 +0100 · Alex Cheema

Files touched

M exo/orchestration/standard_node.py

Diff

commit 41dd700ff4315845ae0539be75596bd5f5ed9dd8
Author: Alex Cheema <alexcheema123@gmail.com>
Date:   Wed Sep 4 17:25:43 2024 +0100

    less aggressive logs for opaque status / download progress. too much spam
---
 exo/orchestration/standard_node.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/exo/orchestration/standard_node.py b/exo/orchestration/standard_node.py
index b6d611db..15e1e16d 100644
--- a/exo/orchestration/standard_node.py
+++ b/exo/orchestration/standard_node.py
@@ -67,7 +67,7 @@ class StandardNode(Node):
             self.current_topology.active_node_id = None
       download_progress = None
       if status_data.get("type", "") == "download_progress":
-        if DEBUG >= 5: print(f"Download progress from {status_data.get('node_id')}: {status_data.get('progress')}")
+        if DEBUG >= 8: print(f"Download progress from {status_data.get('node_id')}: {status_data.get('progress')}")
         download_progress = RepoProgressEvent.from_dict(status_data.get('progress'))
         self.node_download_progress[status_data.get('node_id')] = download_progress
       if self.topology_viz:
@@ -414,7 +414,7 @@ class StandardNode(Node):
     await asyncio.gather(*[send_result_to_peer(peer) for peer in self.peers], return_exceptions=True)
 
   async def broadcast_opaque_status(self, request_id: str, status: str) -> None:
-    if DEBUG >= 5: print(f"Broadcasting opaque status: {request_id=} {status=}")
+    if DEBUG >= 8: print(f"Broadcasting opaque status: {request_id=} {status=}")
 
     async def send_status_to_peer(peer):
       try:

← 4537d614 circleci use tee to output logs in realtime as well as captu · back to Exo · fix Mistral-Large special case when we pass in a path 01cc6a4c →