From 587461978d0c6039d83d3babf8ce4eae164aa1f5 Mon Sep 17 00:00:00 2001 From: tcely Date: Thu, 5 Jun 2025 04:03:01 -0400 Subject: [PATCH] Delay `save_all_media_for_source` while database tasks run --- tubesync/sync/tasks.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/tubesync/sync/tasks.py b/tubesync/sync/tasks.py index 90551676..d7c71a5b 100644 --- a/tubesync/sync/tasks.py +++ b/tubesync/sync/tasks.py @@ -401,6 +401,11 @@ def index_source_task(source_id): wait_for_database_queue( verbose_name=_('Waiting for database tasks to complete'), ) + wait_for_database_queue( + priority=29, # the checking task uses 30 + queue=Val(TaskQueue.FS), + verbose_name=_('Delaying checking all media for database tasks'), + ) delete_task_by_source('sync.tasks.save_all_media_for_source', source.pk) num_videos = len(videos) log.info(f'Found {num_videos} media items for source: {source}')