Do not block waiting for results

This can end up in a dead-lock situation where the execution slot is waiting on a task that is itself waiting on a chance to execute.
This commit is contained in:
tcely authored and GitHub committed 2025-07-05 02:50:11 -04:00
1 parent 129995c065
commit 325c288c5a
1 file changed
+2 -4
+2 -4
View File
@@ -1044,6 +1044,7 @@ def rename_all_media_for_source(source_id):
@dynamic_retry(db_task, delay=600, priority=70, retries=15, queue=Val(TaskQueue.FS))
@huey_lock_task('sync.tasks.save_all_media_for_source', queue=Val(TaskQueue.FS))
def save_all_media_for_source(source_id):
'''
Iterates all media items linked to a source and saves them to
@@ -1103,10 +1104,7 @@ def save_all_media_for_source(source_id):
for media in qs_gen(save_qs)
if str(media.pk) not in saved_later
}
# wait for tasks to complete
res = save_media.map(saved_now)
res.get(blocking=True)
save_media.map(saved_now)
# Old tasks system