diff --git a/backend/app/tasks/downloads.py b/backend/app/tasks/downloads.py
index ea4e023..9185b04 100644
--- a/backend/app/tasks/downloads.py
+++ b/backend/app/tasks/downloads.py
@@ -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)