nessi/language-dashboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add pending_only parameter to start_scan to limit missing German scan to newly added pending items only

Browse Source 
Add pending_only parameter to start_scan() function with default False. Update missing scan path collection to filter for pending items when pending_only=True using (not pending_only or row.get("pending")) check for both movies and series episodes. Update needs_missing_scan check to only trigger when pending items exist without German tracks by adding row.get("pending") condition. Pass pending_only=
This commit is contained in:
nessi
2026-08-26 13:54:14 +02:00
parent 3fb2b34587
commit 00b841fa67
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app.py
+6 -6
View File
@@ -1006,7 +1006,7 @@ def sonarr_groups():
"category":category_key, "category_label":category_label}) "category":category_key, "category_label":category_label})
return sorted(groups, key=lambda x: x["title"].lower()) return sorted(groups, key=lambda x: x["title"].lower())
def start_scan(source, force=False, rows_snapshot=None, series_snapshot=None): def start_scan(source, force=False, rows_snapshot=None, series_snapshot=None, pending_only=False):
with job_lock: with job_lock:
if jobs[source]["state"] == "running" or (jobs[source]["state"] in ("done", "error") and not force): return if jobs[source]["state"] == "running" or (jobs[source]["state"] in ("done", "error") and not force): return
jobs[source] = {"state":"running", "total":0, "done":0, "error":None} jobs[source] = {"state":"running", "total":0, "done":0, "error":None}
@@ -1021,10 +1021,10 @@ def start_scan(source, force=False, rows_snapshot=None, series_snapshot=None):
paths.extend(r["local_path"] for r in group["episodes"] if r["local_path"] != "—" and r["pending"] and not r.get("downloading")) paths.extend(r["local_path"] for r in group["episodes"] if r["local_path"] != "—" and r["pending"] and not r.get("downloading"))
else: else:
for row in rows_snapshot if rows_snapshot is not None else radarr_rows(): for row in rows_snapshot if rows_snapshot is not None else radarr_rows():
if row["local_path"] != "—" and is_german_review_candidate(row) and not row.get("downloading") and not has_german_track(row): paths.append(row["local_path"]) if row["local_path"] != "—" and is_german_review_candidate(row) and not row.get("downloading") and not has_german_track(row) and (not pending_only or row.get("pending")): paths.append(row["local_path"])
if SONARR_URL and SONARR_API_KEY: if SONARR_URL and SONARR_API_KEY:
for group in series_snapshot if series_snapshot is not None else sonarr_groups(): for group in series_snapshot if series_snapshot is not None else sonarr_groups():
paths.extend(r["local_path"] for r in group["episodes"] if r["local_path"] != "—" and is_german_review_candidate(r) and not r.get("downloading") and not has_german_track(r)) paths.extend(r["local_path"] for r in group["episodes"] if r["local_path"] != "—" and is_german_review_candidate(r) and not r.get("downloading") and not has_german_track(r) and (not pending_only or r.get("pending")))
with job_lock: jobs[source]["total"] = len(paths) with job_lock: jobs[source]["total"] = len(paths)
futures = [scan_executor.submit(scan_one, path) for path in paths] futures = [scan_executor.submit(scan_one, path) for path in paths]
for future in as_completed(futures): for future in as_completed(futures):
@@ -1067,14 +1067,14 @@ def refresh_library_cache():
if series and any(row.get("pending") for group in series for row in group["episodes"]): if series and any(row.get("pending") for group in series for row in group["episodes"]):
start_scan("sonarr", force=True, series_snapshot=series) start_scan("sonarr", force=True, series_snapshot=series)
needs_missing_scan = any( needs_missing_scan = any(
row.get("local_path") != "—" and is_german_review_candidate(row) and not has_german_track(row) row.get("local_path") != "—" and is_german_review_candidate(row) and row.get("pending") and not has_german_track(row)
for row in rows for row in rows
) or any( ) or any(
episode.get("local_path") != "—" and is_german_review_candidate(episode) and not has_german_track(episode) episode.get("local_path") != "—" and is_german_review_candidate(episode) and episode.get("pending") and not has_german_track(episode)
for group in series for episode in group["episodes"] for group in series for episode in group["episodes"]
) )
if needs_missing_scan: if needs_missing_scan:
start_scan("missing", force=True, rows_snapshot=rows, series_snapshot=series) start_scan("missing", force=True, rows_snapshot=rows, series_snapshot=series, pending_only=True)
log.info("Bibliotheks-Sync abgeschlossen: %s Filme, %s Serien", len(rows), len(series)) log.info("Bibliotheks-Sync abgeschlossen: %s Filme, %s Serien", len(rows), len(series))
def background_library_sync(): def background_library_sync():