Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-07-22 17:48:09 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Properly keep track of removed streams.

Browse source
This commit is contained in:
SergeantPanda 2025-06-05 21:34:14 -05:00
parent 2359818d7b
commit 767c42a1fe
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
apps/m3u/tasks.py
View file

@ -527,8 +527,12 @@ def cleanup_streams(account_id, scan_start_time=timezone.now):
streams_to_delete.delete()
stale_streams.delete()
total_deleted = deleted_count + stale_count
logger.info(f"Cleanup for M3U account {account_id} complete: {deleted_count} streams removed due to group filter, {stale_count} removed as stale")
# Return the total count of deleted streams
return total_deleted
@shared_task
def refresh_m3u_groups(account_id, use_cache=False, full_refresh=False):
if not acquire_task_lock('refresh_m3u_account_groups', account_id):
@ -1078,7 +1082,7 @@ def refresh_single_m3u_account(account_id):
Stream.objects.filter(id=-1).exists() # This will never find anything but ensures DB sync
# Now run cleanup
cleanup_streams(account_id, refresh_start_timestamp)
streams_deleted = cleanup_streams(account_id, refresh_start_timestamp)
# Calculate elapsed time
elapsed_time = time.time() - start_time