From 991a0c523acf1843ca7672a63bf951c91e5d01a5 Mon Sep 17 00:00:00 2001 From: Sean Ellingham Date: Fri, 26 Sep 2025 13:28:33 +0100 Subject: [PATCH 1/2] Restore pending downloads on start --- app/ytdl.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/app/ytdl.py b/app/ytdl.py index d4955f3..6a6951a 100644 --- a/app/ytdl.py +++ b/app/ytdl.py @@ -240,11 +240,16 @@ class DownloadQueue: async def __import_queue(self): for k, v in self.queue.saved_items(): - await self.add(v.url, v.quality, v.format, v.folder, v.custom_name_prefix, getattr(v, 'playlist_strict_mode', False), getattr(v, 'playlist_item_limit', 0)) + await self.add(v.url, v.quality, v.format, v.folder, v.custom_name_prefix, getattr(v, 'playlist_strict_mode', False), getattr(v, 'playlist_item_limit', 0), getattr(v, 'auto_start', True)) + + async def __import_pending(self): + for k, v in self.pending.saved_items(): + await self.add(v.url, v.quality, v.format, v.folder, v.custom_name_prefix, getattr(v, 'playlist_strict_mode', False), getattr(v, 'playlist_item_limit', 0), getattr(v, 'auto_start', False)) async def initialize(self): log.info("Initializing DownloadQueue") asyncio.create_task(self.__import_queue()) + asyncio.create_task(self.__import_pending()) async def __start_download(self, download): if download.canceled: From cfd464f7be849fe876a47450ae4618f514989fe1 Mon Sep 17 00:00:00 2001 From: Sean Ellingham Date: Fri, 26 Sep 2025 14:07:08 +0100 Subject: [PATCH 2/2] Include auto_start status in add info log --- app/ytdl.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/ytdl.py b/app/ytdl.py index 6a6951a..9e2012b 100644 --- a/app/ytdl.py +++ b/app/ytdl.py @@ -395,7 +395,7 @@ class DownloadQueue: return {'status': 'error', 'msg': f'Unsupported resource "{etype}"'} async def add(self, url, quality, format, folder, custom_name_prefix, playlist_strict_mode, playlist_item_limit, auto_start=True, already=None): - log.info(f'adding {url}: {quality=} {format=} {already=} {folder=} {custom_name_prefix=} {playlist_strict_mode=} {playlist_item_limit=}') + log.info(f'adding {url}: {quality=} {format=} {already=} {folder=} {custom_name_prefix=} {playlist_strict_mode=} {playlist_item_limit=} {auto_start=}') already = set() if already is None else already if url in already: log.info('recursion detected, skipping')