diff --git a/ahserver/websocketProcessor.py b/ahserver/websocketProcessor.py index 6834b53..3b20811 100755 --- a/ahserver/websocketProcessor.py +++ b/ahserver/websocketProcessor.py @@ -128,9 +128,13 @@ class WsPool: async def sendto(self, data, id=None): if id is None: return await ws_send(self.ws, data) - d = self.get_data() - ws = d.get(id) - return await ws_send(ws, data) + try: + d = self.get_data() + ws = d.get(id) + return await ws_send(ws, data) + except Exception as e: + print('ws.sendto() error:', e) + return False class WebsocketProcessor(PythonScriptProcessor): @classmethod