starred/decluttarr
1
0
Fork 0
mirror of https://github.com/ManiMatter/decluttarr.git synced 2026-04-26 10:45:39 +02:00
Code Issues Packages Projects Releases Wiki Activity

debug

Browse Source
This commit is contained in:
Benjamin Harder
2024-05-24 23:47:24 +02:00
parent 93a3ca165e
commit 236258640c
2 changed files with 2 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/jobs/remove_failed_imports.py
View File

@@ -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

40
src/jobs/remove_no_format_upgrade.py
View File

@@ -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