Use asyncio.run on windows

Author: toby-coleman

plugboard/_zmq/zmq_proxy.py

@@ -7,11 +7,15 @@
 import typing as _t
 
 from pydantic import BaseModel, Field, ValidationError
-import uvloop
 import zmq
 import zmq.asyncio
 
 
+try:
+    from uvloop import run as _asyncio_run
+except ImportError:  # pragma: no cover
+    from asyncio import run as _asyncio_run
+
 zmq_sockopts_t: _t.TypeAlias = list[tuple[int, int | bytes | str]]
 ZMQ_ADDR: str = r"tcp://127.0.0.1"
 
@@ -163,7 +167,7 @@ def _start_proxy(
     def _run_process(self) -> None:
         """Entry point for the child process."""
         try:
-            uvloop.run(self._run())
+            _asyncio_run(self._run())
         finally:  # pragma: no cover
             self._close()
 

plugboard/utils/async_utils.py

@@ -4,7 +4,11 @@
 from concurrent.futures import ThreadPoolExecutor
 import typing as _t
 
-import uvloop
+
+try:
+    from uvloop import run as _asyncio_run
+except ImportError:  # pragma: no cover
+    from asyncio import run as _asyncio_run
 
 
 async def gather_except(*coros: _t.Coroutine) -> list[_t.Any]:
@@ -18,7 +22,7 @@ async def gather_except(*coros: _t.Coroutine) -> list[_t.Any]:
 
 def _run_coro_in_thread(coro: _t.Coroutine, timeout: _t.Optional[float] = None) -> _t.Any:
     def _target() -> _t.Any:
-        return uvloop.run(coro)
+        return _asyncio_run(coro)
 
     with ThreadPoolExecutor() as pool:
         future = pool.submit(_target)
@@ -36,7 +40,7 @@ def run_coro_sync(coro: _t.Coroutine, timeout: _t.Optional[float] = None) -> _t.
         loop = asyncio.get_running_loop()
     except RuntimeError:  # pragma: no cover
         # No loop running in current thread
-        return uvloop.run(coro)
+        return _asyncio_run(coro)
 
     if loop.is_running():
         # Run coroutine in new thread with dedicated event loop.