From c145987b0f3e5009a541e90bba113d84327f6cca Mon Sep 17 00:00:00 2001
From: tcely <tcely@users.noreply.github.com>
Date: Wed, 9 Apr 2025 00:04:08 -0400
Subject: [PATCH 1/2] Use distinct transactions

---
 .../sync/management/commands/reset-tasks.py   | 37 +++++++++++--------
 1 file changed, 22 insertions(+), 15 deletions(-)

diff --git a/tubesync/sync/management/commands/reset-tasks.py b/tubesync/sync/management/commands/reset-tasks.py
index d7818007..3d6f515d 100644
--- a/tubesync/sync/management/commands/reset-tasks.py
+++ b/tubesync/sync/management/commands/reset-tasks.py
@@ -13,21 +13,28 @@ class Command(BaseCommand):
 
     help = 'Resets all tasks'
 
-    @atomic(durable=True)
     def handle(self, *args, **options):
         log.info('Resettings all tasks...')
-        # Delete all tasks
-        Task.objects.all().delete()
-        # Iter all tasks
-        for source in Source.objects.all():
-            # Recreate the initial indexing task
-            log.info(f'Resetting tasks for source: {source}')
-            verbose_name = _('Index media from source "{}"')
-            index_source_task(
-                str(source.pk),
-                repeat=source.index_schedule,
-                verbose_name=verbose_name.format(source.name)
-            )
-            # This also chains down to call each Media objects .save() as well
-            source.save()
+        with atomic(durable=True):
+            # Delete all tasks
+            Task.objects.all().delete()
+            # Iter all sources, creating new tasks
+            for source in Source.objects.all():
+                verbose_name = _('Check download directory exists for source "{}"')
+                check_source_directory_exists(
+                    str(source.pk),
+                    verbose_name=verbose_name.format(source.name),
+                )
+                # Recreate the initial indexing task
+                log.info(f'Resetting tasks for source: {source}')
+                verbose_name = _('Index media from source "{}"')
+                index_source_task(
+                    str(source.pk),
+                    repeat=source.index_schedule,
+                    verbose_name=verbose_name.format(source.name),
+                )
+        with atomic(durable=True):
+            for source in Source.objects.all():
+                # This also chains down to call each Media objects .save() as well
+                source.save()
         log.info('Done')

From 6278030a9bb0c7a89df2f60f1b9a5fdd7b6e5db9 Mon Sep 17 00:00:00 2001
From: tcely <tcely@users.noreply.github.com>
Date: Wed, 9 Apr 2025 00:10:26 -0400
Subject: [PATCH 2/2] Check source directory when tasks were reset

---
 tubesync/sync/views.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/tubesync/sync/views.py b/tubesync/sync/views.py
index f489144b..0e3f8dbb 100644
--- a/tubesync/sync/views.py
+++ b/tubesync/sync/views.py
@@ -931,6 +931,11 @@ class ResetTasks(FormView):
         Task.objects.all().delete()
         # Iter all tasks
         for source in Source.objects.all():
+            verbose_name = _('Check download directory exists for source "{}"')
+            check_source_directory_exists(
+                str(source.pk),
+                verbose_name=verbose_name.format(source.name),
+            )
             # Recreate the initial indexing task
             verbose_name = _('Index media from source "{}"')
             index_source_task(