.

Author: spacemanspiff2007

.github/workflows/run_tests.yml

@@ -19,7 +19,7 @@ jobs:
     strategy:
       max-parallel: 4
       matrix:
-        python-version: ['3.8', '3.9', '3.10', '3.11', '3.12', '3.13']
+        python-version: ['3.8', '3.9', '3.10', '3.11', '3.12', '3.13', '3.14']
 
     steps:
     - uses: actions/checkout@v5

src/pyartnet/base/background_task.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import logging
-from asyncio import Task, create_task, sleep
+from asyncio import Task, create_task, current_task, sleep
 from time import monotonic
 from traceback import format_exc
 from typing import Any, Callable, Coroutine, Final
@@ -40,16 +40,17 @@ def start(self) -> None:
         return None
 
     def cancel(self) -> None:
-        if self.task is None:
+        if (task := self.task) is None:
             return None
 
-        self.task.cancel()
         self.task = None
+        task.cancel()
+        return None
 
     async def coro_wrap(self) -> None:
         log.debug(f'Started {self.name}')
         task = self.task
-        assert task is not None
+        assert task is current_task()
 
         try:
             await self.coro()
@@ -65,7 +66,7 @@ class ExceptionIgnoringTask(SimpleBackgroundTask):
     async def coro_wrap(self) -> None:
         log.debug(f'Started {self.name}')
         task = self.task
-        assert task is not None
+        assert task is current_task()
 
         wait = 0
 
@@ -80,10 +81,7 @@ async def coro_wrap(self) -> None:
 
                     # simple sleep logic with an increasing timeout
                     time_to_exception = monotonic() - start
-                    if time_to_exception < 16 or time_to_exception < wait:
-                        wait = max(2, wait * 2)
-                    else:
-                        wait = 0
+                    wait = max(2, wait * 2) if time_to_exception < 16 or time_to_exception < wait else 0
 
                     log.debug(f'Retry in {wait:d} seconds')
         finally: