From 2fef103ea04a2cf051f8877ed0d1d900efd83315 Mon Sep 17 00:00:00 2001 From: tcely Date: Thu, 5 Jun 2025 13:16:33 -0400 Subject: [PATCH] Don't remove based on `task_hash` --- tubesync/sync/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tubesync/sync/tasks.py b/tubesync/sync/tasks.py index 1fb68d50..e0d7cd50 100644 --- a/tubesync/sync/tasks.py +++ b/tubesync/sync/tasks.py @@ -359,7 +359,7 @@ def migrate_to_metadata(media_id): media.save_to_metadata(field, value) -@background(schedule=dict(priority=0, run_at=0), queue=Val(TaskQueue.NET), remove_existing_tasks=True) +@background(schedule=dict(priority=0, run_at=0), queue=Val(TaskQueue.NET), remove_existing_tasks=False) def wait_for_database_queue(): while Task.objects.unlocked(timezone.now()).filter(queue=Val(TaskQueue.DB)).count() > 0: time.sleep(5)