Drop Python 3.9 and 3.10 compat

Author: puddly

.github/workflows/ci.yml

@@ -10,7 +10,7 @@ jobs:
     with:
       CODE_FOLDER: bellows
       CACHE_VERSION: 2
-      PYTHON_VERSION_DEFAULT: 3.9.15
+      PYTHON_VERSION_DEFAULT: 3.11.0
       PRE_COMMIT_CACHE_PATH:  ~/.cache/pre-commit
       MINIMUM_COVERAGE_PERCENTAGE: 99
     secrets:

bellows/ash.py

@@ -2,6 +2,7 @@
 
 import abc
 import asyncio
+from asyncio import timeout as asyncio_timeout
 import binascii
 from collections.abc import Coroutine
 import contextlib
@@ -12,11 +13,6 @@
 import time
 import typing
 
-if sys.version_info[:2] < (3, 11):
-    from async_timeout import timeout as asyncio_timeout  # pragma: no cover
-else:
-    from asyncio import timeout as asyncio_timeout  # pragma: no cover
-
 from zigpy.types import BaseDataclassMixin
 
 import bellows.types as t
@@ -675,7 +671,7 @@ async def _send_data_frame(self, frame: AshFrame) -> None:
                             "NCP has entered into a failed state, not retrying"
                         )
                         raise
-                    except asyncio.TimeoutError:
+                    except TimeoutError:
                         _LOGGER.debug(
                             "No ACK received in %0.2fs (attempt %d) for %r",
                             self._t_rx_ack,

bellows/ezsp/__init__.py

@@ -3,24 +3,19 @@
 from __future__ import annotations
 
 import asyncio
+from asyncio import timeout as asyncio_timeout
 import collections
+from collections.abc import Callable, Generator
 import contextlib
 import dataclasses
 import functools
 import logging
-import sys
-from typing import Any, Callable, Generator
+from typing import Any
 import urllib.parse
 
-from bellows.ash import NcpFailure
-
-if sys.version_info[:2] < (3, 11):
-    from async_timeout import timeout as asyncio_timeout  # pragma: no cover
-else:
-    from asyncio import timeout as asyncio_timeout  # pragma: no cover
-
 import zigpy.config
 
+from bellows.ash import NcpFailure
 import bellows.config as conf
 from bellows.exception import EzspError, InvalidCommandError, InvalidCommandPayload
 from bellows.ezsp import xncp
@@ -119,7 +114,7 @@ async def startup_reset(self) -> None:
             try:
                 async with asyncio_timeout(NETWORK_COORDINATOR_STARTUP_RESET_WAIT):
                     await self._gw.wait_for_startup_reset()
-            except asyncio.TimeoutError:
+            except TimeoutError:
                 pass
             else:
                 LOGGER.debug("Received a reset on startup, not resetting again")

bellows/ezsp/protocol.py

@@ -2,21 +2,16 @@
 
 import abc
 import asyncio
+from asyncio import timeout as asyncio_timeout
 import binascii
+from collections.abc import AsyncGenerator, Callable, Iterable
 import functools
 import logging
-import sys
 import time
-from typing import TYPE_CHECKING, Any, AsyncGenerator, Callable, Iterable
-
-import zigpy.state
-
-if sys.version_info[:2] < (3, 11):
-    from async_timeout import timeout as asyncio_timeout  # pragma: no cover
-else:
-    from asyncio import timeout as asyncio_timeout  # pragma: no cover
+from typing import TYPE_CHECKING, Any
 
 from zigpy.datastructures import PriorityDynamicBoundedSemaphore
+import zigpy.state
 
 from bellows.config import CONF_EZSP_POLICIES
 from bellows.exception import InvalidCommandError

bellows/ezsp/v4/__init__.py

@@ -1,9 +1,9 @@
 """"EZSP Protocol version 4 command."""
 from __future__ import annotations
 
+from collections.abc import AsyncGenerator, Iterable
 import logging
 import random
-from typing import AsyncGenerator, Iterable
 
 import voluptuous as vol
 import zigpy.state
@@ -189,11 +189,11 @@ async def set_source_route(self, nwk: t.NWK, relays: list[t.NWK]) -> t.sl_Status
 
     async def read_counters(self) -> dict[t.EmberCounterType, t.uint16_t]:
         (res,) = await self.readCounters()
-        return dict(zip(t.EmberCounterType, res))
+        return dict(zip(t.EmberCounterType, res, strict=False))
 
     async def read_and_clear_counters(self) -> dict[t.EmberCounterType, t.uint16_t]:
         (res,) = await self.readAndClearCounters()
-        return dict(zip(t.EmberCounterType, res))
+        return dict(zip(t.EmberCounterType, res, strict=False))
 
     async def set_extended_timeout(
         self, nwk: t.NWK, ieee: t.EUI64, extended_timeout: bool = True

bellows/ezsp/xncp.py

@@ -1,9 +1,9 @@
 """Custom EZSP commands."""
 from __future__ import annotations
 
+from collections.abc import Callable
 import dataclasses
 import logging
-from typing import Callable
 
 import zigpy.types as t
 

bellows/thread.py

@@ -2,7 +2,6 @@
 from concurrent.futures import ThreadPoolExecutor
 import functools
 import logging
-import sys
 
 LOGGER = logging.getLogger(__name__)
 
@@ -35,10 +34,7 @@ async def start(self):
         if self.loop is not None and not self.loop.is_closed():
             return
 
-        executor_opts = {"max_workers": 1}
-        if sys.version_info[:2] >= (3, 6):
-            executor_opts["thread_name_prefix"] = __name__
-        executor = ThreadPoolExecutor(**executor_opts)
+        executor = ThreadPoolExecutor(max_workers=1, thread_name_prefix=__name__)
 
         thread_started_future = current_loop.create_future()
 

bellows/types/__init__.py

@@ -13,7 +13,7 @@ def deserialize_dict(data, schema):
 
 def serialize_dict(args, kwargs, schema):
     params = {
-        **dict(zip(schema.keys(), args)),
+        **dict(zip(schema.keys(), args, strict=False)),
         **kwargs,
     }
 

bellows/uart.py

@@ -1,11 +1,6 @@
 import asyncio
+from asyncio import timeout as asyncio_timeout
 import logging
-import sys
-
-if sys.version_info[:2] < (3, 11):
-    from async_timeout import timeout as asyncio_timeout  # pragma: no cover
-else:
-    from asyncio import timeout as asyncio_timeout  # pragma: no cover
 
 import zigpy.config
 import zigpy.serial

bellows/zigbee/application.py

@@ -1,19 +1,13 @@
 from __future__ import annotations
 
 import asyncio
-from datetime import datetime, timezone
+from asyncio import timeout as asyncio_timeout
+from collections.abc import AsyncGenerator
+from datetime import UTC, datetime
+import importlib.metadata
 import logging
 import os
 import statistics
-import sys
-from typing import AsyncGenerator
-
-if sys.version_info[:2] < (3, 11):
-    from async_timeout import timeout as asyncio_timeout  # pragma: no cover
-else:
-    from asyncio import timeout as asyncio_timeout  # pragma: no cover
-
-import importlib.metadata
 
 import zigpy.application
 import zigpy.config
@@ -843,7 +837,7 @@ async def _packet_capture(self, channel: int):
             with self._ezsp.callback_for_commands(
                 {"mfglibRxHandler"},
                 callback=lambda _, response: queue.put_nowait(
-                    (datetime.now(timezone.utc), response)
+                    (datetime.now(UTC), response)
                 ),
             ):
                 while True:
@@ -1096,7 +1090,7 @@ async def _watchdog_feed(self):
                     cnt._last_reset_value = 0
 
                 LOGGER.debug("%s", counters)
-        except (asyncio.TimeoutError, EzspError) as exc:
+        except (TimeoutError, EzspError) as exc:
             # TODO: converted Silvercrest gateways break without this
             LOGGER.warning("Watchdog heartbeat timeout: %s", repr(exc))
             self._watchdog_failures += 1