fix: pass download_id in process_download to prevent retry skip

2026-03-18 23:27:15 -04:00
parent a50677efd0
commit 6036c34680
1 changed files with 1 additions and 1 deletions
@@ -571,7 +571,7 @@ def process_download(self, download_id: int):
                    return {"download_id": download_id, "status": "error", "error": "No source associated"}

                # Delegate to download_source
-                return await _download_source_async(download.source_id)
+                return await _download_source_async(download.source_id, download_id=download_id)
        finally:
            await _cleanup_engine(engine)