From 767c42a1fe3eb381fbf6590370a60f71e96a13da Mon Sep 17 00:00:00 2001 From: SergeantPanda Date: Thu, 5 Jun 2025 21:34:14 -0500 Subject: [PATCH] Properly keep track of removed streams. --- apps/m3u/tasks.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/apps/m3u/tasks.py b/apps/m3u/tasks.py index e5159605..ce46a2ec 100644 --- a/apps/m3u/tasks.py +++ b/apps/m3u/tasks.py @@ -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