From d75e80d40b9bbf0a33909931c13d639941e95b38 Mon Sep 17 00:00:00 2001 From: gufengc Date: Mon, 27 Oct 2025 12:33:33 +0800 Subject: [PATCH 1/2] chore(lattica): upgrade lattica to 1.0.8 --- pyproject.toml | 2 +- src/parallax/p2p/server.py | 5 +++-- src/parallax/server/node_chat_http_server.py | 1 + 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index fabc88c1..992eae2c 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -31,7 +31,7 @@ dependencies = [ "py-machineid", "protobuf==6.31.1", "dijkstar==2.6.0", - "lattica==1.0.7", + "lattica==1.0.8", ] [project.scripts] diff --git a/src/parallax/p2p/server.py b/src/parallax/p2p/server.py index 159ab580..6ea5ef49 100644 --- a/src/parallax/p2p/server.py +++ b/src/parallax/p2p/server.py @@ -306,7 +306,7 @@ def run(self): node_info = self.get_node_info() if node_info == {}: logger.error("Failed to get node info, try again after 10 seconds") - del self.lattica + self.lattica.close() self.lattica = None time.sleep(10) return self.run() @@ -642,7 +642,8 @@ def shutdown(self): self.announcer.join() if self.routing_table_updater is not None: self.routing_table_updater.join() - + if self.lattica is not None: + self.lattica.close() def launch_p2p_server( initial_peers: List[str], diff --git a/src/parallax/server/node_chat_http_server.py b/src/parallax/server/node_chat_http_server.py index e1762325..d6abd345 100644 --- a/src/parallax/server/node_chat_http_server.py +++ b/src/parallax/server/node_chat_http_server.py @@ -143,6 +143,7 @@ def build_lattica(self): logger.warning("Scheduler peer id not found, waiting for 1 second.") time.sleep(1) + self.lattica.close() return False def chat_completion(self, request_data, request_id: str, received_ts: int): From 74a66336683d5d64962777d9b3ecd1445bcaa1f1 Mon Sep 17 00:00:00 2001 From: gufengc Date: Mon, 27 Oct 2025 13:16:35 +0800 Subject: [PATCH 2/2] update --- src/parallax/p2p/server.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/parallax/p2p/server.py b/src/parallax/p2p/server.py index 6ea5ef49..cea2c62a 100644 --- a/src/parallax/p2p/server.py +++ b/src/parallax/p2p/server.py @@ -645,6 +645,7 @@ def shutdown(self): if self.lattica is not None: self.lattica.close() + def launch_p2p_server( initial_peers: List[str], scheduler_addr: Optional[str],