From 5d30601dc1a1dd33391258cc28d726a87da6c98d Mon Sep 17 00:00:00 2001 From: liyonghua0910 Date: Tue, 30 Sep 2025 17:15:05 +0800 Subject: [PATCH] [fix] fix ipc signal suffix for ep --- fastdeploy/worker/worker_process.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/fastdeploy/worker/worker_process.py b/fastdeploy/worker/worker_process.py index 2b2ed9a591..5129eb80c5 100644 --- a/fastdeploy/worker/worker_process.py +++ b/fastdeploy/worker/worker_process.py @@ -197,7 +197,7 @@ def init_health_status(self) -> None: name="launched_expert_service_signal", array=launched_expert_service_signal_data, dtype=np.int32, - suffix=self.parallel_config.engine_worker_queue_port, + suffix=self.parallel_config.engine_pid, create=False, ) while self.launched_expert_service_signal.value[self.local_rank % self.max_chips_per_node] == 0: @@ -214,7 +214,7 @@ def init_health_status(self) -> None: name="worker_ready_signal", array=workers_ready, dtype=np.int32, - suffix=self.parallel_config.engine_worker_queue_port, + suffix=self.parallel_config.engine_pid, create=False, ) self.worker_ready_signal.value[self.local_rank % self.max_chips_per_node] = 1 @@ -425,7 +425,7 @@ def initialize_kv_cache(self) -> None: name="get_profile_block_num", array=get_profile_block_num, dtype=np.int32, - suffix=self.parallel_config.engine_worker_queue_port, + suffix=self.parallel_config.engine_pid, create=False, ) self.get_profile_block_num_signal.value[0] = num_blocks_local @@ -468,7 +468,7 @@ def load_model(self) -> None: name="loaded_model_signal", array=loaded_model_signal_data, dtype=np.int32, - suffix=self.parallel_config.engine_worker_queue_port, + suffix=self.parallel_config.engine_pid, create=False, ) if self.ranks > 1: