diff --git a/app/utils/websocket_tool.py b/app/utils/websocket_tool.py index 98e3039..ae40ae2 100644 --- a/app/utils/websocket_tool.py +++ b/app/utils/websocket_tool.py @@ -60,7 +60,7 @@ class WebsocketUtil: def send_message_proj_json(self, message: Union[str, int, List, Dict], id: str): # 广播该项目的消息 - active_connections_dist = read(id="{id}.pkl") + active_connections_dist = read(id=id) for connection in active_connections_dist[id]: try: connection.send(json.dumps(message, cls=MyEncoder, indent=4), )