From eeb99d2af54a2d57a568aa6c0dcc750540c92bf0 Mon Sep 17 00:00:00 2001
From: Yonghua Li <39643373+liyonghua0910@users.noreply.github.com>
Date: Tue, 16 Dec 2025 17:39:03 +0800
Subject: [PATCH] [BugFix] skip model executing after clearing/updating is done
 (#5527)

* [fix] fix ep loop

* [fix] another try

* [fix] again
---
 fastdeploy/worker/worker_process.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/fastdeploy/worker/worker_process.py b/fastdeploy/worker/worker_process.py
index e289e9897..7bbdc12ba 100644
--- a/fastdeploy/worker/worker_process.py
+++ b/fastdeploy/worker/worker_process.py
@@ -476,6 +476,7 @@ class PaddleDisWorkerProc:
                     logger.info(f"Rank: {self.local_rank} has updated or cleared parameters.")
                     while self.model_weights_status.value[0] == ModelWeightsStatus.CLEARED:
                         time.sleep(0.01)
+                    continue
 
             if self.exist_task_signal.value[0] == ExistTaskStatus.EXIST or self.task_queue.read_finish_flag.get() == 1:
                 logger.info(f"Rank: {self.local_rank} Detected new requests.")