fixes #89

Author: WolfgangFahl

ngwidgets/__init__.py

@@ -1 +1 @@
-__version__ = "0.28.0"
+__version__ = "0.29.0"

ngwidgets/task_runner.py

@@ -40,31 +40,32 @@ def is_running(self) -> bool:
         running = self.task and not self.task.done()
         return running
 
-    def run_async(self, coro_func: Callable[[], asyncio.Future]):
+    def run(self, func: Callable, *args, **kwargs):
         """
-        Run a pure async function in the background.
+        Automatically detect function type and run appropriately.
 
         Args:
-            coro_func: a non-blocking async function
+            func: async or sync function
+            *args, **kwargs: arguments to pass to func
         """
-        if not inspect.iscoroutinefunction(coro_func):
-            raise TypeError("run_async expects an async def function (not called yet).")
-        self._start(coro_func)
+        if inspect.iscoroutinefunction(func):
+            self.run_async(func, *args, **kwargs)
+        else:
+            self.run_blocking(func, *args, **kwargs)
 
-    def run_blocking(self, blocking_func: Callable[[], any]):
+    def run_blocking(self, blocking_func: Callable, *args, **kwargs):
         """
         Run a blocking (sync) function via asyncio.to_thread.
 
         Args:
             blocking_func: a regular function doing I/O or CPU-heavy work
+            *args, **kwargs: arguments to pass to blocking_func
         """
-        if inspect.iscoroutinefunction(blocking_func) or inspect.iscoroutine(
-            blocking_func
-        ):
+        if inspect.iscoroutinefunction(blocking_func) or inspect.iscoroutine(blocking_func):
             raise TypeError("run_blocking expects a sync function, not async.")
 
         async def wrapper():
-            await asyncio.to_thread(blocking_func)
+            await asyncio.to_thread(blocking_func, *args, **kwargs)
 
         self._start(wrapper)
 
@@ -81,19 +82,29 @@ def run_async_wrapping_blocking(self, coro_func: Callable[[], asyncio.Future]):
             )
         self._start(coro_func)
 
-    def _start(self, coro_func: Callable[[], asyncio.Future]):
+    def run_async(self, coro_func: Callable[..., asyncio.Future], *args, **kwargs):
+        """
+        Run a pure async function in the background.
+
+        Args:
+            coro_func: a non-blocking async function
+            *args, **kwargs: arguments to pass to coro_func
+        """
+        if not inspect.iscoroutinefunction(coro_func):
+            raise TypeError("run_async expects an async def function (not called yet).")
+        self._start(coro_func, *args, **kwargs)
+
+    def _start(self, coro_func: Callable[..., asyncio.Future], *args, **kwargs):
         self.cancel_running()
 
         async def wrapped():
             try:
                 if self.progress:
                     self.progress.reset()
                     self.progress.set_description("Working...")
-                await asyncio.wait_for(coro_func(), timeout=self.timeout)
+                await asyncio.wait_for(coro_func(*args, **kwargs), timeout=self.timeout)
             except asyncio.TimeoutError:
-                self.log.log(
-                    "❌", "timeout", "Task exceeded timeout — possible blocking code?"
-                )
+                self.log.log("❌", "timeout", "Task exceeded timeout — possible blocking code?")
             except asyncio.CancelledError:
                 self.log.log("⚠️", "cancelled", "Task was cancelled.")
             except Exception as ex:

ngwidgets/version.py

@@ -17,7 +17,7 @@ class Version:
     name = "ngwidgets"
     version = ngwidgets.__version__
     date = "2023-09-10"
-    updated = "2025-06-19"
+    updated = "2025-07-21"
     description = "NiceGUI widgets"
 
     authors = "Wolfgang Fahl"