[HiSparse PD & PP]Fix HiSparse compatibility with PP decode (#27258)
This commit is contained in:
@@ -1392,6 +1392,9 @@ class SchedulerPPMixin:
|
|||||||
released_reqs = self.disagg_decode_transfer_queue.pop_transferred(
|
released_reqs = self.disagg_decode_transfer_queue.pop_transferred(
|
||||||
release_rids
|
release_rids
|
||||||
)
|
)
|
||||||
|
if self.enable_hisparse:
|
||||||
|
for req in released_reqs:
|
||||||
|
self.hisparse_coordinator.admit_request_direct(req)
|
||||||
self.waiting_queue.extend(released_reqs)
|
self.waiting_queue.extend(released_reqs)
|
||||||
return [req.rid for req in released_reqs]
|
return [req.rid for req in released_reqs]
|
||||||
return None
|
return None
|
||||||
|
|||||||
Reference in New Issue
Block a user