danvics/soulsync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

wishlist auto restart timer check

Browse source
This commit is contained in:
Broque Thomas 2025-12-01 10:26:46 -08:00
parent 9575d8983c
commit 44b1050dca
2 changed files with 26 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/watchlist_scanner.py
View file

@ -1285,8 +1285,8 @@ class WatchlistScanner:
# Clear existing cache # Clear existing cache
self.database.clear_discovery_recent_albums() self.database.clear_discovery_recent_albums()
# IMPROVED: 14-day window (like Spotify Release Radar) instead of 90 days # IMPROVED: 30-day window for better content variety while staying recent
cutoff_date = datetime.now() - timedelta(days=14) cutoff_date = datetime.now() - timedelta(days=30)
cached_count = 0 cached_count = 0
albums_checked = 0 albums_checked = 0

21
web_server.py
View file

@ -9923,8 +9923,11 @@ def _run_full_missing_tracks_process(batch_id, playlist_id, tracks_json):
# PHASE 2: TRANSITION TO DOWNLOAD (if necessary) # PHASE 2: TRANSITION TO DOWNLOAD (if necessary)
if not missing_tracks: if not missing_tracks:
print(f"✅ Analysis for batch {batch_id} complete. No missing tracks.") print(f"✅ Analysis for batch {batch_id} complete. No missing tracks.")
is_auto_batch = False
with tasks_lock: with tasks_lock:
if batch_id in download_batches: if batch_id in download_batches:
is_auto_batch = download_batches[batch_id].get('auto_initiated', False)
download_batches[batch_id]['phase'] = 'complete' download_batches[batch_id]['phase'] = 'complete'
# Update YouTube playlist phase to 'download_complete' if this is a YouTube playlist # Update YouTube playlist phase to 'download_complete' if this is a YouTube playlist
@ -9940,6 +9943,12 @@ def _run_full_missing_tracks_process(batch_id, playlist_id, tracks_json):
if tidal_playlist_id in tidal_discovery_states: if tidal_playlist_id in tidal_discovery_states:
tidal_discovery_states[tidal_playlist_id]['phase'] = 'download_complete' tidal_discovery_states[tidal_playlist_id]['phase'] = 'download_complete'
print(f"📋 Updated Tidal playlist {tidal_playlist_id} to download_complete phase (no missing tracks)") print(f"📋 Updated Tidal playlist {tidal_playlist_id} to download_complete phase (no missing tracks)")
# Handle auto-initiated wishlist completion even when no missing tracks
if is_auto_batch and playlist_id == 'wishlist':
print("🤖 [Auto-Wishlist] No missing tracks found - calling auto-completion handler to toggle cycle and reschedule")
missing_download_executor.submit(_process_failed_tracks_to_wishlist_exact_with_auto_completion, batch_id)
return return
print(f" transitioning batch {batch_id} to download phase with {len(missing_tracks)} tracks.") print(f" transitioning batch {batch_id} to download phase with {len(missing_tracks)} tracks.")
@ -9993,8 +10002,11 @@ def _run_full_missing_tracks_process(batch_id, playlist_id, tracks_json):
print(f"❌ Master worker for batch {batch_id} failed: {e}") print(f"❌ Master worker for batch {batch_id} failed: {e}")
import traceback import traceback
traceback.print_exc() traceback.print_exc()
is_auto_batch = False
with tasks_lock: with tasks_lock:
if batch_id in download_batches: if batch_id in download_batches:
is_auto_batch = download_batches[batch_id].get('auto_initiated', False)
download_batches[batch_id]['phase'] = 'error' download_batches[batch_id]['phase'] = 'error'
download_batches[batch_id]['error'] = str(e) download_batches[batch_id]['error'] = str(e)
@ -10005,6 +10017,15 @@ def _run_full_missing_tracks_process(batch_id, playlist_id, tracks_json):
youtube_playlist_states[url_hash]['phase'] = 'discovered' youtube_playlist_states[url_hash]['phase'] = 'discovered'
print(f"📋 Reset YouTube playlist {url_hash} to discovered phase (error)") print(f"📋 Reset YouTube playlist {url_hash} to discovered phase (error)")
# Handle auto-initiated wishlist errors - reset flag and reschedule timer
if is_auto_batch and playlist_id == 'wishlist':
print("❌ [Auto-Wishlist] Master worker error - resetting auto-processing flag and rescheduling timer")
global wishlist_auto_processing, wishlist_auto_processing_timestamp
with wishlist_timer_lock:
wishlist_auto_processing = False
wishlist_auto_processing_timestamp = 0
schedule_next_wishlist_processing()
def _run_post_processing_worker(task_id, batch_id): def _run_post_processing_worker(task_id, batch_id):
""" """
NEW VERIFICATION WORKFLOW: Post-processing worker that only sets 'completed' status NEW VERIFICATION WORKFLOW: Post-processing worker that only sets 'completed' status