Minor changes ahead of 3.15

mikeshardmind · mikeshardmind · commit 60d719f2de77 · 2025-11-04T18:04:25.000-05:00
diff --git a/.editorconfig b/.editorconfig
@@ -9,11 +9,11 @@ indent_size = 4
 
 [*.py]
 indent_style = space
-max_line_length = 90
+max_line_length = 80
 
 [*.pyi]
 indent_style = space
-max_line_length = 90
+max_line_length = 80
 
 [*.md]
 indent_style = space
diff --git a/.github/workflows/lint.yml b/.github/workflows/lint.yml
@@ -18,7 +18,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: [ '3.12', '3.13', '3.14-dev' ]
+        python-version: [ '3.12', '3.13', '3.14' ]
 
     name: "Type Coverage and Linting @ ${{ matrix.python-version }}"
     steps:
@@ -37,10 +37,10 @@ jobs:
           python -m pip install .
 
       - name: "Run Pyright @ ${{ matrix.python-version }}"
-        if: ${{ matrix.python-version != '3.14-dev' }}
         uses: jakebailey/pyright-action@v2
         with:
           warnings: false
+          verify-types: "async_utils"
 
       - name: Lint check
         uses: astral-sh/ruff-action@v3
diff --git a/_misc/_ensure_annotations.py b/_misc/_ensure_annotations.py
@@ -24,7 +24,9 @@
 
 _cycle_blocked = False
 
-rec = partial(compile, filename="<string>", mode="exec", flags=0, dont_inherit=True)
+rec = partial(
+    compile, filename="<string>", mode="exec", flags=0, dont_inherit=True
+)
 
 
 def ensure_annotations[T: type | FunctionType](f: T) -> T:
@@ -55,7 +57,7 @@ def ensure_annotations[T: type | FunctionType](f: T) -> T:
 
 def version_specific_annotation_interactions(obj: Any) -> None:
     if sys.version_info[:2] >= (3, 14):
-        import annotationlib  # pyright: ignore[reportMissingImports]
+        import annotationlib  # pyright: ignore[reportMissingTypeStubs]
 
         if isinstance(obj, type):
             for t in inspect.getmro(obj):
diff --git a/_misc/_l.py b/_misc/_l.py
@@ -42,7 +42,9 @@ async def amain():
             for x in (True, False)
         ]
         start = time.monotonic_ns()
-        tsks = {loop.run(check(lock, start)) for loop in loops for _ in range(10)}
+        tsks = {
+            loop.run(check(lock, start)) for loop in loops for _ in range(10)
+        }
         results = await asyncio.gather(*tsks)
         results.sort()
         print(*(f"{s} {e}" for s, e in results), sep="\n", flush=True)  # noqa: T201
diff --git a/_misc/_queue_testing.py b/_misc/_queue_testing.py
@@ -32,7 +32,9 @@
 log = logging.getLogger()
 
 dt_fmt = "%Y-%m-%d %H:%M:%S"
-FMT = logging.Formatter("[%(asctime)s] [%(levelname)-8s}] %(name)s: %(message)s", dt_fmt)
+FMT = logging.Formatter(
+    "[%(asctime)s] [%(levelname)-8s}] %(name)s: %(message)s", dt_fmt
+)
 
 
 _MSG_PREFIX = "\x1b[30;1m%(asctime)s\x1b[0m "
@@ -48,7 +50,9 @@
 )
 
 FORMATS = {
-    level: logging.Formatter(_MSG_PREFIX + color + _MSG_POSTFIX, "%Y-%m-%d %H:%M:%S")
+    level: logging.Formatter(
+        _MSG_PREFIX + color + _MSG_POSTFIX, "%Y-%m-%d %H:%M:%S"
+    )
     for level, color in LC
 }
 
diff --git a/pyproject.toml b/pyproject.toml
@@ -137,7 +137,7 @@ reportDuplicateImport = "none"  # handled by ruff
 
 [tool.ruff]
 
-line-length = 90
+line-length = 80
 target-version = "py312"
 preview = true
 
@@ -189,7 +189,6 @@ ignore = [
     "TC003", # I prefer to avoid if TYPE_CHECKING
     "UP007", # "Use | For Union" doesn't account for typevar tuple unpacking.
     "UP031", # No, I like % formatting more for some things...
-    "UP038", # isinstance on union types... perf + type construct symmetry issues.
     # As PYI058 modifies return values to be more narrow than they actually are
     "PYI058", # This opinionated "fix" causes incompatabilties with things expecting a generator.
 ]
diff --git a/src/async_utils/_paramkey.py b/src/async_utils/_paramkey.py
@@ -40,7 +40,9 @@ def __eq__(self, other: object, /) -> bool:
 _marker: tuple[object] = (object(),)
 
 
-def make_key(args: tuple[t.Any, ...], kwds: Mapping[t.Any, object], /) -> Hashable:
+def make_key(
+    args: tuple[t.Any, ...], kwds: Mapping[t.Any, object], /
+) -> Hashable:
     key: tuple[t.Any, ...] = args
     if kwds:
         key += _marker
diff --git a/src/async_utils/_qs.py b/src/async_utils/_qs.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import sys
 import threading
@@ -467,7 +469,9 @@ async def async_get(self, /) -> T:
 
         return item
 
-    def sync_get(self, /, *, blocking: bool = True, timeout: float | None = None) -> T:
+    def sync_get(
+        self, /, *, blocking: bool = True, timeout: float | None = None
+    ) -> T:
         """Get an item from the queue.
 
         Parameters
diff --git a/src/async_utils/_simple_lock.py b/src/async_utils/_simple_lock.py
@@ -12,6 +12,8 @@
 #   See the License for the specific language governing permissions and
 #   limitations under the License.
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf
 import threading
diff --git a/src/async_utils/bg_loop.py b/src/async_utils/bg_loop.py
@@ -16,6 +16,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf
 import threading
diff --git a/src/async_utils/bg_tasks.py b/src/async_utils/bg_tasks.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import time
 from collections.abc import Coroutine
diff --git a/src/async_utils/corofunc_cache.py b/src/async_utils/corofunc_cache.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf
 from collections.abc import Awaitable, Callable, Coroutine, Hashable, Mapping
@@ -103,7 +105,9 @@ def corocache(
         key_func = make_key
     else:
 
-        def key_func(args: tuple[t.Any, ...], kwds: dict[t.Any, t.Any], /) -> Hashable:
+        def key_func(
+            args: tuple[t.Any, ...], kwds: dict[t.Any, t.Any], /
+        ) -> Hashable:
             return make_key(*cache_transform(args, kwds))
 
     def wrapper[**P, R](coro: CoroLike[P, R], /) -> CoroFunc[P, R]:
@@ -182,7 +186,9 @@ def lrucorocache(
         key_func = make_key
     else:
 
-        def key_func(args: tuple[t.Any, ...], kwds: dict[t.Any, t.Any], /) -> Hashable:
+        def key_func(
+            args: tuple[t.Any, ...], kwds: dict[t.Any, t.Any], /
+        ) -> Hashable:
             return make_key(*cache_transform(args, kwds))
 
     def wrapper[**P, R](coro: CoroLike[P, R], /) -> CoroFunc[P, R]:
diff --git a/src/async_utils/dual_color.py b/src/async_utils/dual_color.py
@@ -14,6 +14,20 @@
 
 from __future__ import annotations
 
-from ._qs import BaseQueue, LIFOQueue, PriorityQueue, Queue, QueueEmpty, QueueFull
+from ._qs import (
+    BaseQueue,
+    LIFOQueue,
+    PriorityQueue,
+    Queue,
+    QueueEmpty,
+    QueueFull,
+)
 
-__all__ = ("BaseQueue", "LIFOQueue", "PriorityQueue", "Queue", "QueueEmpty", "QueueFull")
+__all__ = (
+    "BaseQueue",
+    "LIFOQueue",
+    "PriorityQueue",
+    "Queue",
+    "QueueEmpty",
+    "QueueFull",
+)
diff --git a/src/async_utils/gen_transform.py b/src/async_utils/gen_transform.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf  #: PYUPDATE: py3.15, check cf.Future use
 from asyncio import FIRST_COMPLETED as FC
@@ -114,7 +116,9 @@ async def gen() -> AsyncGenerator[Y]:
             while not bg_task.done():
                 try:
                     q_get = asyncio.ensure_future(q.async_get())
-                    done, _ = await asyncio.wait((bg_task, q_get), return_when=FC)
+                    done, _ = await asyncio.wait(
+                        (bg_task, q_get), return_when=FC
+                    )
                     if q_get in done:
                         lazy_ev.clear()
                         yield (await q_get)
diff --git a/src/async_utils/lockout.py b/src/async_utils/lockout.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf
 import heapq
@@ -72,7 +74,11 @@ def __init_subclass__(cls) -> t.Never:
 
     def __repr__(self) -> str:
         res = super().__repr__()
-        x = f"locked, timestamps={self._lockouts:!r}" if self._lockouts else "unlocked"
+        x = (
+            f"locked, timestamps={self._lockouts:!r}"
+            if self._lockouts
+            else "unlocked"
+        )
         return f"<{res[1:-1]} [{x}]>"
 
     def __init__(self) -> None:
@@ -140,7 +146,11 @@ def __init__(self) -> None:
 
     def __repr__(self) -> str:
         res = super().__repr__()
-        x = f"locked, timestamps={self._lockouts:!r}" if self._lockouts else "unlocked"
+        x = (
+            f"locked, timestamps={self._lockouts:!r}"
+            if self._lockouts
+            else "unlocked"
+        )
         return f"<{res[1:-1]} [{x}]>"
 
     def lockout_for(self, seconds: float, /) -> None:
diff --git a/src/async_utils/lru.py b/src/async_utils/lru.py
@@ -16,9 +16,8 @@
 
 from __future__ import annotations
 
-# PYUPDATE: 3.14 release + 3.14 minimum: reaudit
-# heapq methods are not threadsafe pre 3.14
-# see: GH: cpython 135036
+__lazy_modules__ = ["asyncio"]
+
 import heapq
 import math
 import sys
diff --git a/src/async_utils/priority_sem.py b/src/async_utils/priority_sem.py
@@ -15,6 +15,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import concurrent.futures as cf
 import contextvars
@@ -29,13 +31,17 @@
 __all__ = ("PrioritySemaphore", "priority_context")
 
 
-_priority: contextvars.ContextVar[int] = contextvars.ContextVar("_priority", default=0)
+_priority: contextvars.ContextVar[int] = contextvars.ContextVar(
+    "_priority", default=0
+)
 
 
 class _PriorityWaiter:
     __slots__ = ("future", "ord")
 
-    def __init__(self, priority: int, ts: float, future: cf.Future[None], /) -> None:
+    def __init__(
+        self, priority: int, ts: float, future: cf.Future[None], /
+    ) -> None:
         self.future: cf.Future[None] = future
         self.ord: tuple[int, float] = (priority, ts)
 
diff --git a/src/async_utils/ratelimiter.py b/src/async_utils/ratelimiter.py
@@ -15,6 +15,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 import time
 from collections import deque
@@ -52,7 +54,9 @@ def __init_subclass__(cls) -> t.Never:
 
     __final__ = True
 
-    def __init__(self, rate_limit: int, period: float, granularity: float) -> None:
+    def __init__(
+        self, rate_limit: int, period: float, granularity: float
+    ) -> None:
         self.rate_limit: int = rate_limit
         self.period: float = period
         self.granularity: float = granularity
@@ -70,7 +74,9 @@ async def __aenter__(self) -> None:
 
             now = time.monotonic()
             with self._lock:
-                while self._monotonics and (now - self._monotonics[0] > self.period):
+                while self._monotonics and (
+                    now - self._monotonics[0] > self.period
+                ):
                     self._monotonics.popleft()
 
         with self._lock:
diff --git a/src/async_utils/scheduler.py b/src/async_utils/scheduler.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio"]
+
 import asyncio
 from functools import total_ordering
 from time import time
@@ -110,7 +112,9 @@ async def __anext__(self) -> T:
                 self.__tqueue.task_done()
         raise StopAsyncIteration
 
-    async def create_task(self, timestamp: float, payload: T, /) -> CancellationToken:
+    async def create_task(
+        self, timestamp: float, payload: T, /
+    ) -> CancellationToken:
         """Create a task.
 
         Parameters
diff --git a/src/async_utils/sig_service.py b/src/async_utils/sig_service.py
@@ -14,6 +14,8 @@
 
 from __future__ import annotations
 
+__lazy_modules__ = ["asyncio", "select", "signal", "socket"]
+
 import enum
 import select
 import signal
diff --git a/src/async_utils/task_cache.py b/src/async_utils/task_cache.py
diff --git a/src/async_utils/waterfall.py b/src/async_utils/waterfall.py
