OP#8343:

Extract helper function

Author: briemla

OTAnalytics/plugin_ui/nicegui_gui/pages/sections_and_flow_form/flow_form.py

@@ -1,9 +1,9 @@
-import asyncio
 from typing import Iterable, Self
 
 from nicegui import ui
 from nicegui.elements.button import Button
 from nicegui.events import ClickEventArguments
+from plugin_ui.utils.asyncio_helper import run_async
 
 from OTAnalytics.adapter_ui.abstract_frame import AbstractFrame
 from OTAnalytics.adapter_ui.abstract_treeview_interface import AbstractTreeviewInterface
@@ -109,7 +109,7 @@ def generate_flow(self) -> None:
         self._viewmodel.generate_flows()
 
     def remove_flow(self) -> None:
-        asyncio.create_task(self._viewmodel.remove_flows())
+        run_async(self._viewmodel.remove_flows())
 
     async def show_flow_properties(self) -> None:
         await self._viewmodel.edit_selected_flow()

OTAnalytics/plugin_ui/nicegui_gui/pages/sections_and_flow_form/sections_form.py

@@ -1,8 +1,8 @@
-import asyncio
 from typing import Any, Iterable, Self
 
 from nicegui import ui
 from nicegui.elements.button import Button
+from plugin_ui.utils.asyncio_helper import run_async
 
 from OTAnalytics.adapter_ui.abstract_treeview_interface import AbstractTreeviewInterface
 from OTAnalytics.adapter_ui.view_model import ViewModel
@@ -140,7 +140,7 @@ def update_selected_items(self, item_ids: list[str]) -> None:
         self._section_table.select(item_ids)
 
     def remove_sections(self) -> None:
-        asyncio.create_task(self._viewmodel.remove_sections())
+        run_async(self._viewmodel.remove_sections())
 
     def update_items(self) -> None:
         self._section_table.update(map_to_ui(self._viewmodel.get_all_sections()))

OTAnalytics/plugin_ui/utils/__init__.py

@@ -0,0 +1,12 @@
+import asyncio
+from typing import Coroutine
+
+
+def run_async(coro: Coroutine) -> None:
+    # Schedule the asynchronous removal so tests see the call immediately
+    # while NiceGUI executes the coroutine in the event loop.
+    try:
+        asyncio.create_task(coro)
+    except RuntimeError:
+        # No running loop available; run the coroutine to completion
+        asyncio.run(coro)