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}')