ignore not_started progress updates

90e0e2761f4f202bf63541e9606a4fea3da97fbd · 2025-01-27 06:05:59 +0000 · Alex Cheema

Files touched

M exo/main.py

Diff

commit 90e0e2761f4f202bf63541e9606a4fea3da97fbd
Author: Alex Cheema <alexcheema123@gmail.com>
Date:   Mon Jan 27 06:05:59 2025 +0000

    ignore not_started progress updates
---
 exo/main.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/exo/main.py b/exo/main.py
index 8f6c5e57..2dd75bf2 100644
--- a/exo/main.py
+++ b/exo/main.py
@@ -221,6 +221,7 @@ last_broadcast_time = 0
 def throttled_broadcast(shard: Shard, event: RepoProgressEvent):
   global last_broadcast_time
   current_time = time.time()
+  if event.status == "not_started": return
   if event.status == "complete" or current_time - last_broadcast_time >= 0.1:
     last_broadcast_time = current_time
     asyncio.create_task(node.broadcast_opaque_status("", json.dumps({"type": "download_progress", "node_id": node.id, "progress": event.to_dict()})))

← 265586f7 set timeout on get too · back to Exo · fix eta/speed for resuming an existing download, using the s 7c649085 →