From 236258640c9d0172deef41b5d0a02e2b80f922ba Mon Sep 17 00:00:00 2001 From: Benjamin Harder Date: Fri, 24 May 2024 23:47:24 +0200 Subject: [PATCH] debug --- src/jobs/remove_failed_imports.py | 4 +-- src/jobs/remove_no_format_upgrade.py | 40 ---------------------------- 2 files changed, 2 insertions(+), 42 deletions(-) delete mode 100644 src/jobs/remove_no_format_upgrade.py diff --git a/src/jobs/remove_failed_imports.py b/src/jobs/remove_failed_imports.py index 7d15246..e8fb429 100644 --- a/src/jobs/remove_failed_imports.py +++ b/src/jobs/remove_failed_imports.py @@ -22,8 +22,8 @@ async def remove_failed_imports(settingsDict, BASE_URL, API_KEY, NAME, deleted_d and queueItem['trackedDownloadStatus'] == 'warning' \ and queueItem['trackedDownloadState'] == 'importPending': - for status_message in queueItem['statusMessages']: - if not settingsDict['FAILED_IMPORT_MESSAGE_PATTERNS'] or any(any(pattern in message for pattern in settingsDict['FAILED_IMPORT_MESSAGE_PATTERNS']) for message in messages): + for statusMessage in queueItem['statusMessages']: + if not settingsDict['FAILED_IMPORT_MESSAGE_PATTERNS'] or any(any(pattern in message for pattern in settingsDict['FAILED_IMPORT_MESSAGE_PATTERNS']) for message in statusMessage.get('messages', [])): affectedItems.append(queueItem) break diff --git a/src/jobs/remove_no_format_upgrade.py b/src/jobs/remove_no_format_upgrade.py deleted file mode 100644 index 4e0cad0..0000000 --- a/src/jobs/remove_no_format_upgrade.py +++ /dev/null @@ -1,40 +0,0 @@ -from src.utils.shared import (errorDetails, formattedQueueInfo, get_queue, privateTrackerCheck, protectedDownloadCheck, execute_checks, permittedAttemptsCheck, remove_download) -import sys, os, traceback -import logging, verboselogs -logger = verboselogs.VerboseLogger(__name__) - -async def remove_no_format_upgrade(settingsDict, BASE_URL, API_KEY, NAME, deleted_downloads, defective_tracker, protectedDownloadIDs, privateDowloadIDs): - # Detects downloads stuck downloading meta data and triggers repeat check and subsequent delete. Adds to blocklist - try: - failType = 'no format upgrade' - queue = await get_queue(BASE_URL, API_KEY) - logger.debug('remove_no_format_upgrade/queue IN: %s', formattedQueueInfo(queue)) - if not queue: return 0 - # Find items affected - affectedItems = [] - for queueItem in queue['records']: - if 'status' in queueItem \ - and 'trackedDownloadStatus' in queueItem \ - and 'trackedDownloadState' in queueItem \ - and 'statusMessages' in queueItem: - - if queueItem['status'] == 'completed' \ - and queueItem['trackedDownloadStatus'] == 'warning' \ - and queueItem['trackedDownloadState'] == 'importPending': - - for status_message in queueItem['statusMessages']: - if any(message.startswith("Not a Custom Format upgrade for existing") or message.startswith("Not an upgrade for existing") for message in status_message.get('messages', [])): - affectedItems.append(queueItem) - break - - affectedItems = await execute_checks(settingsDict, affectedItems, failType, BASE_URL, API_KEY, NAME, deleted_downloads, defective_tracker, privateDowloadIDs, protectedDownloadIDs, - addToBlocklist = True, - doPrivateTrackerCheck = False, - doProtectedDownloadCheck = True, - doPermittedAttemptsCheck = False, - extraParameters = ['keepTorrentForPrivateTrackers'] - ) - return len(affectedItems) - except Exception as error: - errorDetails(NAME, error) - return 0