Remove lock on connect (#74)

numat · Sep 12, 2023 · b7bb215 · b7bb215
1 parent 59ba2cd
commit b7bb215
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/watlow/util.py b/watlow/util.py
@@ -49,14 +49,13 @@ def _detect_pymodbus_version(self) -> None:
 
     async def _connect(self):
         """Start asynchronous reconnect loop."""
-        async with self.lock:
-            try:
-                if self.pymodbus30plus:
-                    await asyncio.wait_for(self.client.connect(), timeout=self.timeout)  # 3.x
-                else:  # 2.4.x - 2.5.x
-                    await self.client.start(self.ip)  # type: ignore
-            except Exception:
-                raise OSError(f"Could not connect to '{self.ip}'.")
+        try:
+            if self.pymodbus30plus:
+                await asyncio.wait_for(self.client.connect(), timeout=self.timeout)  # 3.x
+            else:  # 2.4.x - 2.5.x
+                await self.client.start(self.ip)  # type: ignore
+        except Exception:
+            raise OSError(f"Could not connect to '{self.ip}'.")
 
     async def read_coils(self, address, count):
         """Read modbus output coils (0 address prefix)."""