fix(fhempy): release readingsBeginUpdate lock after 120s if no readin…

…gsEndUpdate received
fhempy · Dec 17, 2022 · 3607d18 · 3607d18
1 parent cc1414b
commit 3607d18
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/FHEM/bindings/python/fhempy/lib/fhem.py b/FHEM/bindings/python/fhempy/lib/fhem.py
@@ -102,7 +102,13 @@ async def setDevAttrList(name, attr_list):
 async def readingsBeginUpdate(hash):
     if hash["NAME"] not in update_locks:
         update_locks[hash["NAME"]] = asyncio.Lock()
-    await update_locks[hash["NAME"]].acquire()
+    try:
+        await asyncio.wait_for(update_locks[hash["NAME"]].acquire(), 120)
+    except asyncio.TimeoutError:
+        logging.error(
+            f"{hash['NAME']}: readingsBeginUpdate couldn't acquire lock,"
+            + " caused by readingsBeginUpdate without End or Single update inbetween"
+        )
     cmd = "readingsBeginUpdate($defs{'" + hash["NAME"] + "'});;"
     return await sendCommandHash(hash, cmd)