Schedule a rename task per media item instead

tubesync/sync/signals.py

@@ -73,22 +73,23 @@ def source_post_save(sender, instance, created, **kwargs):
             )
     # Check settings before any rename tasks are scheduled
     rename_sources_setting = settings.RENAME_SOURCES or list()
-    create_rename_task = (
+    create_rename_tasks = (
         (
             instance.directory and
             instance.directory in rename_sources_setting
         ) or
         settings.RENAME_ALL_SOURCES
     )
-    if create_rename_task:
+    if create_rename_tasks:
-        verbose_name = _('Renaming all media for source "{}"')
+        for media in Media.objects.filter(source=instance.pk, downloaded=True):
-        rename_all_media_for_source(
+            verbose_name = _('Renaming media for: {}: "{}"')
-            str(instance.pk),
+            rename_media(
-            queue=str(instance.pk),
+                str(media.pk),
-            priority=1,
+                queue=str(media.pk),
-            verbose_name=verbose_name.format(instance.name),
+                priority=1,
-            remove_existing_tasks=True
+                verbose_name=verbose_name.format(media.key, media.name),
-        )
+                remove_existing_tasks=True
+            )
     verbose_name = _('Checking all media for source "{}"')
     save_all_media_for_source(
         str(instance.pk),