Skip to content

Commit aa80f75

Browse files
committed
[BugFix] reset exist tasks signal in clear_data
1 parent dd2aa10 commit aa80f75

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

fastdeploy/inter_communicator/engine_worker_queue.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -837,6 +837,10 @@ def clear_data(self):
837837
self.lock.acquire()
838838
self.tasks[:] = list()
839839
self.client_read_flag[:] = [1] * self.num_client
840+
if self.is_single_node:
841+
self.exist_tasks_intra_signal.value[0] = 0
842+
else:
843+
self.exist_tasks_inter_signal.set(0)
840844
self.lock.release()
841845
llm_logger.info("clear data for engine worker queue")
842846

0 commit comments

Comments
 (0)