[fix][pd-disag]no need set next batch sampling info done in prefill (#10259)
This commit is contained in:
@@ -2297,8 +2297,9 @@ class Scheduler(
|
|||||||
def set_next_batch_sampling_info_done(self, batch: ScheduleBatch):
|
def set_next_batch_sampling_info_done(self, batch: ScheduleBatch):
|
||||||
if batch.next_batch_sampling_info:
|
if batch.next_batch_sampling_info:
|
||||||
if batch.next_batch_sampling_info.grammars is not None:
|
if batch.next_batch_sampling_info.grammars is not None:
|
||||||
batch.next_batch_sampling_info.update_regex_vocab_mask()
|
if self.disaggregation_mode != DisaggregationMode.PREFILL:
|
||||||
self.current_stream.synchronize()
|
batch.next_batch_sampling_info.update_regex_vocab_mask()
|
||||||
|
self.current_stream.synchronize()
|
||||||
batch.next_batch_sampling_info.sampling_info_done.set()
|
batch.next_batch_sampling_info.sampling_info_done.set()
|
||||||
|
|
||||||
def watchdog_thread(self):
|
def watchdog_thread(self):
|
||||||
|
|||||||
Reference in New Issue
Block a user