hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-25 22:46:34 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Skip downloaded media that was deleted

Browse Source 
Moved the save of media to the end of the function.
This commit is contained in:
tcely 2025-02-09 06:21:39 -05:00 committed by GitHub
parent 8d89cc01f9
commit 365ad555db
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tubesync/sync/signals.py
View File

@ -151,11 +151,6 @@ def media_post_save(sender, instance, created, **kwargs):
if instance.can_download: if instance.can_download:
instance.can_download = False instance.can_download = False
can_download_changed = True can_download_changed = True
# Save the instance if any changes were required
if skip_changed or can_download_changed:
post_save.disconnect(media_post_save, sender=Media)
instance.save()
post_save.connect(media_post_save, sender=Media)
# If the media is missing metadata schedule it to be downloaded # If the media is missing metadata schedule it to be downloaded
if not instance.metadata and not instance.skip and not get_media_metadata_task(instance.pk): if not instance.metadata and not instance.skip and not get_media_metadata_task(instance.pk):
log.info(f'Scheduling task to download metadata for: {instance.url}') log.info(f'Scheduling task to download metadata for: {instance.url}')
@ -185,6 +180,10 @@ def media_post_save(sender, instance, created, **kwargs):
) )
# If the media has not yet been downloaded schedule it to be downloaded # If the media has not yet been downloaded schedule it to be downloaded
if not instance.media_file_exists: if not instance.media_file_exists:
# The file was deleted after it was downloaded, skip this media.
if instance.can_download and instance.downloaded:
skip_changed = True != instance.skip
instance.skip = True
instance.downloaded = False instance.downloaded = False
instance.media_file = None instance.media_file = None
if (not instance.downloaded and instance.can_download and not instance.skip if (not instance.downloaded and instance.can_download and not instance.skip
@ -198,6 +197,11 @@ def media_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
) )
# Save the instance if any changes were required
if skip_changed or can_download_changed:
post_save.disconnect(media_post_save, sender=Media)
instance.save()
post_save.connect(media_post_save, sender=Media)
@receiver(pre_delete, sender=Media) @receiver(pre_delete, sender=Media)