hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-20 03:56:35 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge 1bdd888064 into f5a71592fc

Browse Source
This commit is contained in:
tcely 2025-06-16 14:28:00 +00:00 committed by GitHub
commit df5dba067c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tubesync/sync/signals.py
View File

@ -227,11 +227,7 @@ def media_post_save(sender, instance, created, **kwargs):
settings.RENAME_ALL_SOURCES
)
if create_rename_task:
verbose_name = _('Renaming media for: {}: "{}"')
rename_media(
str(media.pk),
verbose_name=verbose_name.format(media.key, media.name),
)
rename_media(str(media.pk))
# If the media is missing metadata schedule it to be downloaded
if not (media.skip or media.has_metadata or existing_media_metadata_task):
@ -291,7 +287,6 @@ def media_pre_delete(sender, instance, **kwargs):
log.info(f'Deleting tasks for media: {instance.name}')
delete_task_by_media('sync.tasks.download_media', (str(instance.pk),))
delete_task_by_media('sync.tasks.download_media_metadata', (str(instance.pk),))
delete_task_by_media('sync.tasks.rename_media', (str(instance.pk),))
delete_task_by_media('sync.tasks.wait_for_media_premiere', (str(instance.pk),))
thumbnail_url = instance.thumbnail
if thumbnail_url:

5
tubesync/sync/tasks.py
View File

@ -66,7 +66,6 @@ def map_task_to_instance(task):
'sync.tasks.download_media': Media,
'sync.tasks.download_media_metadata': Media,
'sync.tasks.save_all_media_for_source': Source,
'sync.tasks.rename_media': Media,
'sync.tasks.rename_all_media_for_source': Source,
'sync.tasks.wait_for_media_premiere': Media,
'sync.tasks.delete_all_media_for_source': Source,
@ -906,12 +905,12 @@ def refresh_formats(media_id):
save_model(media)
@background(schedule=dict(priority=20, run_at=60), queue=Val(TaskQueue.FS), remove_existing_tasks=True)
@db_task(delay=60, priority=80, retries=5, retry_delay=60, queue=Val(TaskQueue.FS))
def rename_media(media_id):
try:
media = Media.objects.get(pk=media_id)
except Media.DoesNotExist as e:
raise InvalidTaskError(_('no such media')) from e
raise CancelExecution(_('no such media'), retry=False) from e
else:
with atomic():
media.rename_files()