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__(