From ae0f55ae9bfd26c0c99e61f223ec246e3b532816 Mon Sep 17 00:00:00 2001 From: Zoe Roux Date: Sun, 18 May 2025 23:27:58 +0200 Subject: [PATCH] Clear failed requests before scanning --- scanner/scanner/fsscan.py | 2 ++ scanner/scanner/requests.py | 8 ++++++++ 2 files changed, 10 insertions(+) diff --git a/scanner/scanner/fsscan.py b/scanner/scanner/fsscan.py index 47634366..54b06fdd 100644 --- a/scanner/scanner/fsscan.py +++ b/scanner/scanner/fsscan.py @@ -41,6 +41,8 @@ class FsScanner: logger.info("Starting scan at %s. This may take some time...", path) if self._ignore_pattern: logger.info(f"Applying ignore pattern: {self._ignore_pattern}") + await self._requests.clear_failed() + try: videos = self.walk_fs(path) diff --git a/scanner/scanner/requests.py b/scanner/scanner/requests.py index 89d7afa2..c45c107d 100644 --- a/scanner/scanner/requests.py +++ b/scanner/scanner/requests.py @@ -48,6 +48,14 @@ class RequestCreator: ) _ = await self._database.execute("notify scanner_requests") + async def clear_failed(self): + _ = await self._database.execute( + """ + delete from scanner.requests + where status = 'failed' + """ + ) + class RequestProcessor: def __init__(