diff --git a/fastdeploy/worker/worker_process.py b/fastdeploy/worker/worker_process.py index 2153da1eb..c3a3b5076 100644 --- a/fastdeploy/worker/worker_process.py +++ b/fastdeploy/worker/worker_process.py @@ -421,8 +421,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]) - if self.ranks > 1: - 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) req_dicts = None self.worker_healthy_live_signal.value[tp_rank % self.max_chips_per_node] = int(time.time())