[BugFix] reset exist tasks signal in clear_data (#7111)

* [BugFix] reset exist tasks signal in clear_data

* [Fix] fix stale exist tasks signal after weight update

* [Chore] downgrade detected new requests log to DEBUG level

* [fix] adjust continue place

Author: liyonghua0910

fastdeploy/inter_communicator/engine_worker_queue.py

@@ -837,6 +837,10 @@ def clear_data(self):
         self.lock.acquire()
         self.tasks[:] = list()
         self.client_read_flag[:] = [1] * self.num_client
+        if self.is_single_node:
+            self.exist_tasks_intra_signal.value[0] = 0
+        else:
+            self.exist_tasks_inter_signal.set(0)
         self.lock.release()
         llm_logger.info("clear data for engine worker queue")
 

fastdeploy/worker/worker_process.py

@@ -567,10 +567,10 @@ def event_loop_normal(self) -> None:
                             self.model_weights_status.value[0] = (
                                 ModelWeightsStatus.UPDATING
                             )  # 所有 Rank 已同步唤醒，启动权重更新流程
-                            continue
+                    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.")
+                logger.debug(f"Rank: {self.local_rank} Detected new requests.")
                 self.engine_forward_signal.value[0] = 1
                 tasks, read_finish = self.task_queue.get_tasks()
                 # Only one of all tp_size client will get read_finish == True.