Moved download_media_metadata in tasks.py
This commit is contained in:
1 parent
424fda5c52
commit
4f4ff960c2
1 file changed
+9
-9
@@ -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:
|
||||
|
||||
Reference in new issue
Block a user