[Fix] fix stale exist tasks signal after weight update

liyonghua0910 · liyonghua0910 · commit 37a3ed902c60 · 2026-03-31T10:30:42.000Z
diff --git a/fastdeploy/worker/worker_process.py b/fastdeploy/worker/worker_process.py
@@ -549,6 +549,7 @@ def event_loop_normal(self) -> None:
                             f"Rank: {self.local_rank} has updated parameters. {self.model_weights_status.value[0]}"
                         )
                         self.model_weights_signal[0] = ModelWeightsStatus.NORMAL
+                        continue
                     elif self.model_weights_signal[0] == ModelWeightsStatus.CLEARING:
                         logger.info(
                             f"Rank: {self.local_rank} has cleared parameters. {self.model_weights_status.value[0]}"

Original file line number	Diff line number	Diff line change
`@@ -549,6 +549,7 @@ def event_loop_normal(self) -> None:`
`549`	`549`	`f"Rank: {self.local_rank} has updated parameters. {self.model_weights_status.value[0]}"`
`550`	`550`	`)`
`551`	`551`	`self.model_weights_signal[0] = ModelWeightsStatus.NORMAL`
	`552`	`+ continue`
`552`	`553`	`elif self.model_weights_signal[0] == ModelWeightsStatus.CLEARING:`
`553`	`554`	`logger.info(`
`554`	`555`	`f"Rank: {self.local_rank} has cleared parameters. {self.model_weights_status.value[0]}"`