diff options
| author | Maxim Devaev <[email protected]> | 2023-05-04 12:37:05 +0300 |
|---|---|---|
| committer | Maxim Devaev <[email protected]> | 2023-05-04 12:37:05 +0300 |
| commit | b5353e63cd52b0d98e7a56acc5c8fbfc6ad8b3ee (patch) | |
| tree | 3176f1a738b9533e6f3a28b132e4501a6f97f991 /kvmd/plugins | |
| parent | b5d67314977a7e475fac164446031ca7c83b8bc4 (diff) | |
python 3.11 fixes
Diffstat (limited to 'kvmd/plugins')
| -rw-r--r-- | kvmd/plugins/ugpio/tesmart.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/kvmd/plugins/ugpio/tesmart.py b/kvmd/plugins/ugpio/tesmart.py index c7e410f6..1e869ed2 100644 --- a/kvmd/plugins/ugpio/tesmart.py +++ b/kvmd/plugins/ugpio/tesmart.py @@ -137,8 +137,14 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute assert self.__writer is not None try: self.__writer.write(b"\xAA\xBB\x03%s\xEE" % (cmd)) - await asyncio.wait_for(self.__writer.drain(), timeout=self.__timeout) - return (await asyncio.wait_for(self.__reader.readexactly(6), timeout=self.__timeout))[4] + await asyncio.wait_for( + asyncio.ensure_future(self.__writer.drain()), + timeout=self.__timeout, + ) + return (await asyncio.wait_for( + asyncio.ensure_future(self.__reader.readexactly(6)), + timeout=self.__timeout, + ))[4] except Exception as err: get_logger(0).error("Can't send command to TESmart KVM [%s]:%d: %s", self.__host, self.__port, tools.efmt(err)) @@ -155,7 +161,7 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute async def __ensure_device_net(self) -> None: try: (self.__reader, self.__writer) = await asyncio.wait_for( - asyncio.open_connection(self.__host, self.__port), + asyncio.ensure_future(asyncio.open_connection(self.__host, self.__port)), timeout=self.__timeout, ) except Exception as err: |