fix: Run response to HEARTBEAT in asyncio.ensure_future

davidrapan · Dec 18, 2024 · dd7aa49 · dd7aa49
1 parent d7c4e76
commit dd7aa49
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/custom_components/solarman/api.py b/custom_components/solarman/api.py
@@ -104,7 +104,7 @@ def _received_frame_is_valid(self, frame):
             return False
         if frame.startswith(self.v5_start + b"\x01\x00\x10\x47"):
             self.log.debug("[%s] V5_HEARTBEAT: %s", self.serial, frame.hex(" "))
-            execute_async(self._heartbeat_response(frame))
+            asyncio.ensure_future(self._heartbeat_response(frame))
             return False
         return True
 

diff --git a/custom_components/solarman/common.py b/custom_components/solarman/common.py
@@ -32,11 +32,7 @@ async def async_execute(x):
     return await loop.run_in_executor(None, x)
 
 async def async_listdir(path, prefix = ""):
-    return sorted([prefix + f for f in await async_execute(lambda: os.listdir(path)) if os.path.isfile(path + f)]) if os.path.exists(path) else []
-
-def execute_async(x):
-    loop = asyncio.get_event_loop()
-    return loop.run_until_complete(x)
+    return sorted([prefix + f for f in await async_execute(os.listdir(path)) if os.path.isfile(path + f)]) if os.path.exists(path) else []
 
 def get_coordinator_descriptions(hass: HomeAssistant, entry_id: str, platform: str):
     coordinator = hass.data[DOMAIN][entry_id]