wimby/tubesync
1
0 Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

Move refesh_formats to last position in the NET queue

Browse Source
This commit is contained in:
tcely authored and GitHub committed 2025-04-09 02:51:57 -04:00
1 parent a62b64c3ee
commit 3b0ecf29be
1 file changed
+5 -5
Download Patch File Download Diff File Expand all files Collapse all files
tubesync/sync/tasks.py
+5 -5
View File
@@ -240,7 +240,7 @@ def cleanup_removed_media(source, videos):
schedule_media_servers_update() schedule_media_servers_update()
@background(schedule=dict(priority=10, run_at=30), queue=Val(TaskQueue.NET), remove_existing_tasks=True) @background(schedule=dict(priority=20, run_at=30), queue=Val(TaskQueue.NET), remove_existing_tasks=True)
def index_source_task(source_id): def index_source_task(source_id):
''' '''
Indexes media available from a Source object. Indexes media available from a Source object.
@@ -345,7 +345,7 @@ def check_source_directory_exists(source_id):
source.make_directory() source.make_directory()
@background(schedule=dict(priority=5, run_at=10), queue=Val(TaskQueue.NET)) @background(schedule=dict(priority=10, run_at=10), queue=Val(TaskQueue.NET))
def download_source_images(source_id): def download_source_images(source_id):
''' '''
Downloads an image and save it as a local thumbnail attached to a Downloads an image and save it as a local thumbnail attached to a
@@ -395,7 +395,7 @@ def download_source_images(source_id):
log.info(f'Thumbnail downloaded for source with ID: {source_id} / {source}') log.info(f'Thumbnail downloaded for source with ID: {source_id} / {source}')
@background(schedule=dict(priority=20, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True) @background(schedule=dict(priority=40, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True)
def download_media_metadata(media_id): def download_media_metadata(media_id):
''' '''
Downloads the metadata for a media item. Downloads the metadata for a media item.
@@ -517,7 +517,7 @@ def download_media_thumbnail(media_id, url):
return True return True
@background(schedule=dict(priority=15, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True) @background(schedule=dict(priority=30, run_at=60), queue=Val(TaskQueue.NET), remove_existing_tasks=True)
def download_media(media_id): def download_media(media_id):
''' '''
Downloads the media to disk and attaches it to the Media instance. Downloads the media to disk and attaches it to the Media instance.
@@ -707,7 +707,7 @@ def save_all_media_for_source(source_id):
update_task_status(task, None) update_task_status(task, None)
@background(schedule=dict(priority=10, run_at=0), queue=Val(TaskQueue.NET), remove_existing_tasks=True) @background(schedule=dict(priority=50, run_at=0), queue=Val(TaskQueue.NET), remove_existing_tasks=True)
def refesh_formats(media_id): def refesh_formats(media_id):
try: try:
media = Media.objects.get(pk=media_id) media = Media.objects.get(pk=media_id)