From 4f4ff960c2e87fddf7b32d20780994896f440935 Mon Sep 17 00:00:00 2001 From: tcely Date: Tue, 24 Jun 2025 11:19:57 -0400 Subject: [PATCH] Moved `download_media_metadata` in tasks.py --- tubesync/sync/tasks.py | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/tubesync/sync/tasks.py b/tubesync/sync/tasks.py index a622576d..3c04fd89 100644 --- a/tubesync/sync/tasks.py +++ b/tubesync/sync/tasks.py @@ -833,15 +833,6 @@ def download_metadata(media_id): return True -@background(schedule=dict(priority=40, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True) -def download_media_metadata(media_id): - try: - res = download_metadata(media_id) - return res.get(blocking=True) - except CancelExecution as e: - raise InvalidTaskError(str(e)) from e - - @dynamic_retry(db_task, delay=10, priority=90, retries=15, queue=Val(TaskQueue.NET)) def download_media_image(media_id, url): ''' @@ -1056,6 +1047,15 @@ from background_task.exceptions import InvalidTaskError # noqa: E402 from background_task.models import Task, CompletedTask # noqa: E402 +@background(schedule=dict(priority=40, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True) +def download_media_metadata(media_id): + try: + res = download_metadata(media_id) + return res.get(blocking=True) + except CancelExecution as e: + raise InvalidTaskError(str(e)) from e + + @background(schedule=dict(priority=10, run_at=10), queue=Val(TaskQueue.FS), remove_existing_tasks=True) def download_media_thumbnail(media_id, url): try: