|
15 | 15 | "match_import_min": 30, # match % >= this → try force import |
16 | 16 | "match_oversight_max": 30, # match % < this → flag for agent oversight |
17 | 17 | "stale_download_days": 14, # days before a stalled download is deleted + re-searched |
18 | | - "queue_page_size": 500, # how many queue records to fetch at once |
| 18 | + "queue_page_size": 100, # how many queue records to fetch at once |
19 | 19 | "missing_album_scan_count": 10, # how many oldest missing albums to check (kept low to avoid timeouts) |
20 | 20 | "missing_search_threshold": 2, # searches >= this + zero grabs → flag problematic |
21 | 21 |
|
@@ -380,14 +380,14 @@ def main(): |
380 | 380 | # === EXECUTE === |
381 | 381 | results = {"imported": [], "import_failed": [], "deleted": [], "skipped": [], "unknown": []} |
382 | 382 |
|
383 | | - print(f"PHASE 1: Deleting {len(action_delete)} items...") |
| 383 | + print(f"PHASE 1: Deleting {len(action_delete)} items...", flush=True) |
384 | 384 | for i, (rid, title, reason, album_id) in enumerate(action_delete, 1): |
385 | 385 | delete_queue_item(rid, remove_from_client=True, album_id=album_id) |
386 | 386 | results["deleted"].append(title[:60]) |
387 | | - if i % 100 == 0: |
388 | | - print(f" {i}/{len(action_delete)} deleted...") |
| 387 | + if i % 50 == 0: |
| 388 | + print(f" {i}/{len(action_delete)} deleted...", flush=True) |
389 | 389 |
|
390 | | - print(f"\nPHASE 2: Importing {len(action_import)} items...") |
| 390 | + print(f"\nPHASE 2: Importing {len(action_import)} items...", flush=True) |
391 | 391 | for rid, did, title, reason, album_id in action_import: |
392 | 392 | if did: |
393 | 393 | success = try_manual_import(did) |
|
0 commit comments