another attempt to fix multi-processing #173

app/library/Download.py

@@ -28,7 +28,6 @@ class Download:
     """
 
     id: str = None
-    manager = None
     download_dir: str = None
     temp_dir: str = None
     output_template: str = None
@@ -319,6 +318,9 @@ class Download:
                 return
             try:
                 status = await self.update_task
+            except FileNotFoundError:
+                LOG.debug(f"Closing progress update for: {self.info._id=} {status=}.")
+                return
             except Exception as e:
                 LOG.error(f"Failed to get status update for: {self.info._id=}. {e}")
                 LOG.exception(e)

app/library/DownloadQueue.py

@@ -468,6 +468,7 @@ class DownloadQueue:
             await entry.close()
 
         if self.queue.exists(key=id):
+            LOG.debug(f"Download '{id}' is done. Removing from queue.")
             self.queue.delete(key=id)
 
             if entry.is_canceled() is True:
@@ -477,6 +478,8 @@ class DownloadQueue:
 
             self.done.put(value=entry)
             asyncio.create_task(self.emitter.completed(dl=entry.info.serialize()), name=f"notifier-d-{id}")
+        else:
+            LOG.warning(f"Download '{id}' not found in queue.")
 
         if self.event:
             self.event.set()