Store asyncio to prevent (unlikely? impossible?) garbage collection.

Author: JoeZiminski

datashuttle/tui/shared/validate_content.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import asyncio
 import platform
 from typing import TYPE_CHECKING, Optional, Union
 
@@ -192,14 +191,11 @@ def on_button_pressed(self, event: Button.Pressed) -> None:
                         self.validating_central_popup
                     )
 
-                asyncio.create_task(
-                    self.run_validate_and_dismiss_popup(
-                        top_level_folder=top_level_folder,
-                        include_central=include_central,
-                        strict_mode=strict_mode,
-                        allow_letters_in_sub_ses_values=allow_letters_in_sub_ses_values,
-                    ),
-                    name="validate_async_task",
+                self.run_validate_and_dismiss_popup(
+                    top_level_folder=top_level_folder,
+                    include_central=include_central,
+                    strict_mode=strict_mode,
+                    allow_letters_in_sub_ses_values=allow_letters_in_sub_ses_values,
                 )
             else:
                 path_ = self.query_one("#validate_path_input").value
@@ -229,14 +225,21 @@ def set_select_path(self, path_):
         if path_:
             self.query_one("#validate_path_input").value = path_.as_posix()
 
+    @work(group="validate_async", exclusive=True)
     async def run_validate_and_dismiss_popup(
         self,
         top_level_folder,
         include_central,
         strict_mode,
         allow_letters_in_sub_ses_values,
     ) -> None:
-        """Run validation in a worker thread and dismiss the waiting popup when done."""
+        """Run validation in a worker thread and dismiss the waiting popup when done.
+
+        Decorated with ``@work`` so Textual owns the task lifecycle (no need to
+        hold an ``asyncio.Task`` reference to prevent premature GC), and so a
+        repeat button-press cancels the previous in-flight invocation via
+        ``exclusive=True``.
+        """
         worker = self.validate_project_worker(
             top_level_folder=top_level_folder,
             include_central=include_central,

datashuttle/tui/tabs/create_folders.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import asyncio
 from typing import TYPE_CHECKING, List, Optional
 
 if TYPE_CHECKING:
@@ -316,7 +315,7 @@ def suggest_next_sub_ses(
         Shows a pop up screen in cases when searching for next sub/ses takes
         time such as searching central in SSH connection method.
 
-        Creates an asyncio task which handles the suggestion logic and
+        Spawns a Textual worker which handles the suggestion logic and
         dismissing the pop up.
 
         Parameters
@@ -346,13 +345,11 @@ def suggest_next_sub_ses(
             )
             self.mainwindow.push_screen(self.searching_central_popup_widget)
 
-        asyncio.create_task(
-            self.fill_suggestion_and_dismiss_popup(
-                prefix, input_id, include_central
-            ),
-            name=f"suggest_next_{prefix}_async_task",
+        self.fill_suggestion_and_dismiss_popup(
+            prefix, input_id, include_central
         )
 
+    @work(group="suggest_next_async", exclusive=True)
     async def fill_suggestion_and_dismiss_popup(
         self, prefix, input_id, include_central
     ) -> None:
@@ -364,6 +361,11 @@ async def fill_suggestion_and_dismiss_popup(
         Else, if the worker successfully exits, this function handles dismissal
         of the popup.
 
+        Decorated with ``@work`` so Textual owns the task lifecycle (no need to
+        hold an ``asyncio.Task`` reference to prevent premature GC), and so a
+        repeat invocation cancels the previous in-flight one via
+        ``exclusive=True``.
+
         see `suggest_next_sub_ses()` for parameters.
         """
         worker = self.fill_input_with_next_sub_or_ses_template(