Catch TimeoutError.
authorBenjamin Braatz <bb@bbraatz.eu>
Tue, 21 Sep 2021 19:24:11 +0000 (21:24 +0200)
committerBenjamin Braatz <bb@bbraatz.eu>
Tue, 21 Sep 2021 19:24:11 +0000 (21:24 +0200)
controlpi_plugins/wsclient.py

index f0a2263ba2b797e3dc6ce1badf9ce180c7d5e53b..233816c006fd05f33f370e9b6bccb8ce51d2cbb0 100644 (file)
@@ -1,4 +1,5 @@
 import asyncio
+import concurrent.futures
 import fcntl
 import json
 import socket
@@ -196,6 +197,6 @@ class WSClient(BasePlugin):
                     await self.bus.send(Message(self.name,
                                                 {'event':
                                                  'connection closed'}))
-            except (OSError, InvalidMessage):
+            except (OSError, InvalidMessage, concurrent.futures.TimeoutError):
                 pass
             await asyncio.sleep(1)