Drop support for Python 3.7

.github/workflows/test.yml

@@ -11,16 +11,14 @@ jobs:
       fail-fast: false
       matrix:
         os: [ubuntu-latest]
-        python-version:
-          # Add "pypy-3.8", "pypy-3.9" again at some point
-          ["3.7", "3.8", "3.9", "3.10", "3.11"]
+        python-version: ["3.8", "3.9", "3.10", "3.11"]
         include:
           - os: macos-latest
-            python-version: "3.7"
+            python-version: "3.8"
           - os: macos-latest
             python-version: "3.11"
           - os: windows-latest
-            python-version: "3.7"
+            python-version: "3.8"
           - os: windows-latest
             python-version: "3.11"
     runs-on: ${{ matrix.os }}

README.md

@@ -55,7 +55,7 @@ aiomqtt combines the stability of the time-proven [paho-mqtt](https://github.com
 
 ## Installation
 
-aiomqtt can be installed via `pip install aiomqtt`. It requires Python `3.7+` to run. The only dependency is [paho-mqtt](https://github.com/eclipse/paho.mqtt.python).
+aiomqtt can be installed via `pip install aiomqtt`. It requires Python `3.8+` to run. The only dependency is [paho-mqtt](https://github.com/eclipse/paho.mqtt.python).
 
 If you can't wait for the latest version and want to install directly from GitHub, use:
 

aiomqtt/client.py

@@ -112,7 +112,7 @@ def _outgoing_call(
     method: Callable[Concatenate[ClientT, P], Coroutine[Any, Any, T]]
 ) -> Callable[Concatenate[ClientT, P], Coroutine[Any, Any, T]]:
     @functools.wraps(method)
-    async def decorated(self: ClientT, *args: P.args, **kwargs: P.kwargs) -> T:
+    async def decorated(self: ClientT, /, *args: P.args, **kwargs: P.kwargs) -> T:
         if not self._outgoing_calls_sem:
             return await method(self, *args, **kwargs)
 
@@ -549,6 +549,7 @@ def _force_disconnect(self) -> None:
     @_outgoing_call
     async def subscribe(  # noqa: PLR0913
         self,
+        /,
         topic: SubscribeTopic,
         qos: int = 0,
         options: mqtt.SubscribeOptions | None = None,
@@ -589,6 +590,7 @@ async def subscribe(  # noqa: PLR0913
     @_outgoing_call
     async def unsubscribe(
         self,
+        /,
         topic: str | list[str],
         properties: Properties | None = None,
         *args: Any,
@@ -620,6 +622,7 @@ async def unsubscribe(
     @_outgoing_call
     async def publish(  # noqa: PLR0913
         self,
+        /,
         topic: str,
         payload: PayloadType = None,
         qos: int = 0,