Schedule the rename task when only the settings allow it

This commit is contained in:
tcely 2025-01-28 16:19:17 -05:00 committed by GitHub
parent eb27bf1583
commit bf7127b973
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -54,7 +54,7 @@ def source_post_save(sender, instance, created, **kwargs):
if instance.source_type != Source.SOURCE_TYPE_YOUTUBE_PLAYLIST and instance.copy_channel_images: if instance.source_type != Source.SOURCE_TYPE_YOUTUBE_PLAYLIST and instance.copy_channel_images:
download_source_images( download_source_images(
str(instance.pk), str(instance.pk),
priority=0, priority=2,
verbose_name=verbose_name.format(instance.name) verbose_name=verbose_name.format(instance.name)
) )
if instance.index_schedule > 0: if instance.index_schedule > 0:
@ -69,17 +69,28 @@ def source_post_save(sender, instance, created, **kwargs):
verbose_name=verbose_name.format(instance.name), verbose_name=verbose_name.format(instance.name),
remove_existing_tasks=True remove_existing_tasks=True
) )
verbose_name = _('Renaming all media for source "{}"') # Check settings before any rename tasks are scheduled
rename_all_media_for_source( rename_sources_setting = settings.RENAME_SOURCES or list()
str(instance.pk), create_rename_task = (
priority=0, (
verbose_name=verbose_name.format(instance.name), instance.directory and
remove_existing_tasks=True instance.directory in rename_sources_setting
) or
settings.RENAME_ALL_SOURCES
) )
if create_rename_task:
verbose_name = _('Renaming all media for source "{}"')
rename_all_media_for_source(
str(instance.pk),
queue=str(instance.pk),
priority=1,
verbose_name=verbose_name.format(instance.name),
remove_existing_tasks=False
)
verbose_name = _('Checking all media for source "{}"') verbose_name = _('Checking all media for source "{}"')
save_all_media_for_source( save_all_media_for_source(
str(instance.pk), str(instance.pk),
priority=1, priority=2,
verbose_name=verbose_name.format(instance.name), verbose_name=verbose_name.format(instance.name),
remove_existing_tasks=True remove_existing_tasks=True
) )