diff --git a/web_server.py b/web_server.py
index 40627b96..fcafc937 100644
--- a/web_server.py
+++ b/web_server.py
@@ -14843,6 +14843,9 @@ def _on_download_completed(batch_id, task_id, success=True):
         completed_tasks = download_batches[batch_id].setdefault('_completed_task_ids', set())
         if task_id in completed_tasks:
             print(f"⚠️ [Batch Manager] Task {task_id} already completed — skipping duplicate _on_download_completed call")
+            # Set terminal status so the monitor loop stops re-processing this task
+            if task_id in download_tasks and download_tasks[task_id].get('status') in ('downloading', 'queued'):
+                download_tasks[task_id]['status'] = 'completed'
             return
         completed_tasks.add(task_id)