Add CI for Python 3.14 (#132)

* Add ci for Python 3.14
* Filter deprecation warnings for event loop policies, deprecated since Python 3.14

Author: berendkleinhaneveld

.github/workflows/ci.yml

@@ -46,6 +46,8 @@ jobs:
             pyversion: "3.12"
           - name: Linux py313
             pyversion: "3.13"
+          - name: Linux py314
+            pyversion: "3.14"
     steps:
       - uses: actions/checkout@v4
       - name: Install uv

observ/scheduler.py

@@ -49,7 +49,7 @@ def register_request_flush(self, callback):
         self.request_flush = callback
 
     def request_flush_asyncio(self):
-        loop = asyncio.get_event_loop_policy().get_event_loop()
+        loop = asyncio.get_event_loop()
         loop.call_soon(self.flush)
 
     def register_asyncio(self):

observ/watcher.py

@@ -141,6 +141,7 @@ class Watcher(Generic[T]):
         "_deps",
         "_new_deps",
         "_number_of_callback_args",
+        "_tasks",
         "callback",
         "callback_async",
         "deep",
@@ -185,6 +186,7 @@ def __init__(
             if deep is None:
                 deep = True
         self._deps, self._new_deps = WeakSet(), WeakSet()
+        self._tasks = set()
 
         self.sync = sync
         if callable(callback):
@@ -265,11 +267,13 @@ def run_callback(self, new, old) -> None:
                     self._number_of_callback_args = 2
 
         if self.callback_async and maybe_coro:
-            loop = asyncio.get_event_loop_policy().get_event_loop()
+            loop = asyncio.get_event_loop()
             if not loop.is_running():
                 loop.run_until_complete(maybe_coro)
             else:
-                loop.create_task(maybe_coro)
+                task = loop.create_task(maybe_coro)
+                self._tasks.add(task)
+                task.add_done_callback(self._tasks.discard)
 
     def _run_callback(self, *args) -> None:
         """
@@ -296,11 +300,13 @@ def get(self) -> Any:
         try:
             value_or_coro = self.fn()
             if self.fn_async and value_or_coro:
-                loop = asyncio.get_event_loop_policy().get_event_loop()
+                loop = asyncio.get_event_loop()
                 if not loop.is_running():
                     value_or_coro = loop.run_until_complete(value_or_coro)
                 else:
-                    loop.create_task(value_or_coro)
+                    task = loop.create_task(value_or_coro)
+                    self._tasks.add(task)
+                    task.add_done_callback(self._tasks.discard)
                     return
             if self.deep:
                 traverse(value_or_coro)

pyproject.toml

@@ -27,7 +27,7 @@ dev = [
 ]
 ruff = ["ruff"]
 qt = [
-    "PySide6>=6.6.2,!=6.8.3 ; python_version < '3.14'",
+    "PySide6>=6.6.2,!=6.8.3 ; python_version < '3.15'",
     "pytest-qt",
     "pytest-xvfb",
 ]

tests/test_asyncio.py

@@ -12,7 +12,7 @@ def flush(loop):
 
 def create_plain_loop():
     loop = asyncio.new_event_loop()
-    asyncio.get_event_loop_policy().set_event_loop(loop)
+    asyncio.set_event_loop(loop)
     return loop
 
 

tests/test_qt.py

@@ -1,12 +1,17 @@
 import asyncio
+import warnings
 from weakref import ref
 
 import pytest
 
 from observ import reactive, scheduler, watch
 
 try:
-    from PySide6 import QtAsyncio, QtWidgets
+    with warnings.catch_warnings():
+        # Filter deprecation warnings of event loop policies
+        # in Python 3.14, which will be removed in 3.16
+        warnings.filterwarnings("ignore", category=DeprecationWarning)
+        from PySide6 import QtAsyncio, QtWidgets
 
     has_qt = True
 except ImportError:
@@ -16,16 +21,20 @@
 
 @pytest.fixture
 def qtasyncio():
-    old_policy = asyncio.get_event_loop_policy()
-    qt_policy = QtAsyncio.QAsyncioEventLoopPolicy(quit_qapp=False)
-    asyncio.set_event_loop_policy(qt_policy)
-    old_callback = scheduler.request_flush
-    scheduler.register_asyncio()
-    try:
-        yield
-    finally:
-        asyncio.set_event_loop_policy(old_policy)
-        scheduler.register_request_flush(old_callback)
+    with warnings.catch_warnings():
+        # Filter deprecation warnings of event loop policies
+        # in Python 3.14, which will be removed in 3.16
+        warnings.filterwarnings("ignore", category=DeprecationWarning)
+        old_policy = asyncio.get_event_loop_policy()
+        qt_policy = QtAsyncio.QAsyncioEventLoopPolicy(quit_qapp=False)
+        asyncio.set_event_loop_policy(qt_policy)
+        old_callback = scheduler.request_flush
+        scheduler.register_asyncio()
+        try:
+            yield
+        finally:
+            asyncio.set_event_loop_policy(old_policy)
+            scheduler.register_request_flush(old_callback)
 
 
 @pytest.mark.skipif(not has_qt, reason=qt_missing_reason)