From 8e84cceccecb0f75e1a841d0ba5c65817af2e768 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Mon, 29 Apr 2024 15:06:15 +0800 Subject: [PATCH] bugfix --- ahserver/websocketProcessor.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) 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