hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-27 09:26:36 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

The transaction is never committed if the worker is killed

Browse Source
This commit is contained in:
tcely 2025-03-18 18:48:11 -04:00 committed by GitHub
parent 8f9fbb9a4c
commit 61853f49b5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tubesync/sync/signals.py
View File

@ -158,12 +158,6 @@ def source_pre_delete(sender, instance, **kwargs):
priority=1, priority=1,
verbose_name=verbose_name.format(instance.name), verbose_name=verbose_name.format(instance.name),
) )
# Try to do it all immediately
# If this is killed, the scheduled task should do the work instead.
delete_all_media_for_source.now(
str(instance.pk),
str(instance.name),
)
@receiver(post_delete, sender=Source) @receiver(post_delete, sender=Source)
@ -176,11 +170,6 @@ def source_post_delete(sender, instance, **kwargs):
delete_task_by_source('sync.tasks.delete_all_media_for_source', instance.pk) delete_task_by_source('sync.tasks.delete_all_media_for_source', instance.pk)
delete_task_by_source('sync.tasks.rename_all_media_for_source', instance.pk) delete_task_by_source('sync.tasks.rename_all_media_for_source', instance.pk)
delete_task_by_source('sync.tasks.save_all_media_for_source', instance.pk) delete_task_by_source('sync.tasks.save_all_media_for_source', instance.pk)
# Remove the directory, if the user requested that
directory_path = Path(source.directory_path)
if (directory_path / '.to_be_removed').is_file():
log.info(f'Deleting directory for: {source.name}: {directory_path}')
rmtree(directory_path, True)
@receiver(task_failed, sender=Task) @receiver(task_failed, sender=Task)