From b3f78815d87406dd751e2aa597df53dc266c23e8 Mon Sep 17 00:00:00 2001 From: Yuanle Liu Date: Fri, 19 Dec 2025 12:04:18 +0800 Subject: [PATCH] update rl signal (#5650) --- fastdeploy/worker/worker_process.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/fastdeploy/worker/worker_process.py b/fastdeploy/worker/worker_process.py index 77ffdc43d..9092bd3ba 100644 --- a/fastdeploy/worker/worker_process.py +++ b/fastdeploy/worker/worker_process.py @@ -427,7 +427,8 @@ class PaddleDisWorkerProc: if self.fd_config.load_config.dynamic_load_weight: if self.model_weights_status.value[0] != ModelWeightsStatus.NORMAL: self.model_weights_signal[0] = int(self.model_weights_status.value[0]) - self.model_weights_signal[0] = self._broadcast_model_weights_signal(src=0, group=None) + if self.ranks > 1: + self.model_weights_signal[0] = self._broadcast_model_weights_signal(src=0, group=None) self.insert_step = False req_dicts = None @@ -450,7 +451,8 @@ class PaddleDisWorkerProc: if self.fd_config.load_config.dynamic_load_weight: if self.model_weights_signal[0] != ModelWeightsStatus.NORMAL: - paddle.distributed.barrier() + if self.ranks > 1: + paddle.distributed.barrier() logger.info( f"Rank: {self.local_rank} to update or clear parameters, signal is {self.model_weights_signal[0]}, [-1:clear, 1:update]" )