danvics/ytptube
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Handle Download queue task exceptions

Browse source
This commit is contained in:
arabcoders 2025-06-24 17:38:11 +03:00
parent de304005da
commit 388ed0bf9d
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
app/library/DownloadQueue.py
View file

@ -720,11 +720,9 @@ class DownloadQueue(metaclass=Singleton):
if entry.started() or entry.is_cancelled(): if entry.started() or entry.is_cancelled():
continue continue
# Bypass semaphore for temporary workers asyncio.create_task(
if entry.is_live: self._download_temp(_id, entry) if entry.is_live else self._download(_id, entry)
asyncio.create_task(self._download_temp(_id, entry)) ).add_done_callback(self._handle_task_exception)
else:
asyncio.create_task(self._download(_id, entry))
await asyncio.sleep(0.5) await asyncio.sleep(0.5)
@ -894,3 +892,10 @@ class DownloadQueue(metaclass=Singleton):
self.done.put(item) self.done.put(item)
LOG.exception(e) LOG.exception(e)
LOG.error(f"Failed to retry item '{item_ref}'. {e!s}") LOG.error(f"Failed to retry item '{item_ref}'. {e!s}")
def _handle_task_exception(self, task: asyncio.Task):
if task.cancelled():
return
if exc := task.exception():
LOG.error(f"Unhandled exception in background task: {exc!s}")