Confine req-pool-idx assignment to the pool allocator (#25726)
This commit is contained in:
@@ -1774,9 +1774,7 @@ class ScheduleBatch(ScheduleBatchDisaggregationDecodeMixin):
|
|||||||
self.extend_num_tokens = extend_num_tokens
|
self.extend_num_tokens = extend_num_tokens
|
||||||
|
|
||||||
# Allocate memory
|
# Allocate memory
|
||||||
out_cache_loc, req_pool_indices_tensor, req_pool_indices = alloc_for_extend(
|
out_cache_loc, req_pool_indices_tensor, _ = alloc_for_extend(self)
|
||||||
self
|
|
||||||
)
|
|
||||||
|
|
||||||
# Set fields
|
# Set fields
|
||||||
input_embeds = []
|
input_embeds = []
|
||||||
@@ -1792,7 +1790,6 @@ class ScheduleBatch(ScheduleBatchDisaggregationDecodeMixin):
|
|||||||
mamba_track_seqlens_cpu = []
|
mamba_track_seqlens_cpu = []
|
||||||
|
|
||||||
for i, (req, seq_len, pre_len) in enumerate(zip(reqs, seq_lens, prefix_lens)):
|
for i, (req, seq_len, pre_len) in enumerate(zip(reqs, seq_lens, prefix_lens)):
|
||||||
req.req_pool_idx = req_pool_indices[i]
|
|
||||||
assert seq_len - pre_len == req.extend_input_len
|
assert seq_len - pre_len == req.extend_input_len
|
||||||
|
|
||||||
req.extend_batch_idx += 1
|
req.extend_batch_idx += 1
|
||||||
|
|||||||
Reference in New Issue
Block a user