feat: task and use_task for better asyncio task a thread execution

use_task can replace use_thread, but also support coroutine functions.

task is a decorator that creates a top level task that can be executed
from any location (e.g. a click handler of a button).

.github/workflows/codequality.yaml

@@ -25,7 +25,7 @@ jobs:
           python-version: ${{ matrix.python-version }}
       - name: Install dependencies
         run: |
-          pip install ".[dev]" mypy==0.991 black==22.12.0 codespell==2.2.4 "click<8.1.4" "traitlets<5.10.0" "matplotlib<3.8.0"
+          pip install ".[dev]" mypy==1.1.1 black==22.12.0 codespell==2.2.4 "click<8.1.4" "traitlets<5.10.0" "matplotlib<3.8.0"
           mypy --install-types --non-interactive solara
       - name: Run codespell
         run: codespell

.pre-commit-config.yaml

@@ -28,7 +28,7 @@ repos:
         files: \.py$
         args: [--profile=black]
   - repo: https://github.com/pre-commit/mirrors-mypy
-    rev: "v0.991" # Use the sha / tag you want to point at
+    rev: "v1.1.1" # Use the sha / tag you want to point at
     hooks:
       - id: mypy
         args: [--no-strict-optional, --ignore-missing-imports]

solara/lab/__init__.py

@@ -1,6 +1,7 @@
 # isort: skip_file
 from .components import *  # noqa: F401, F403
 from ..server.kernel_context import on_kernel_start  # noqa: F401
+from ..tasks import task, use_task, Task  # noqa: F401, F403
 from ..toestand import computed  # noqa: F401
 
 

solara/server/starlette.py

@@ -90,19 +90,19 @@ async def process_messages_task(self):
                     await self.ws.send_text(first)
 
     def close(self):
-        self.portal.call(self.ws.close)
+        self.portal.call(self.ws.close)  # type: ignore
 
     def send_text(self, data: str) -> None:
         if settings.main.experimental_performance:
             self.to_send.append(data)
         else:
-            self.portal.call(self.ws.send_bytes, data)
+            self.portal.call(self.ws.send_bytes, data)  # type: ignore
 
     def send_bytes(self, data: bytes) -> None:
         if settings.main.experimental_performance:
             self.to_send.append(data)
         else:
-            self.portal.call(self.ws.send_bytes, data)
+            self.portal.call(self.ws.send_bytes, data)  # type: ignore
 
     async def receive(self):
         if hasattr(self.portal, "start_task_soon"):