[Bugfix] Add warnings when NSA indexer cache indice mismatch in PD module (#18727)
This commit is contained in:
@@ -643,6 +643,13 @@ class MooncakeKVManager(CommonKVManager):
|
|||||||
raise RuntimeError(
|
raise RuntimeError(
|
||||||
f"PD Disaggregation does NOT support PD different TP sizes for non-MLA {state_type.upper()} hybrid models yet."
|
f"PD Disaggregation does NOT support PD different TP sizes for non-MLA {state_type.upper()} hybrid models yet."
|
||||||
)
|
)
|
||||||
|
if len(prefill_state_indices) < len(req.dst_state_indices):
|
||||||
|
logger.warning(
|
||||||
|
f"len(prefill_state_indices) = {len(prefill_state_indices)}, len(dst_state_indices) = {len(req.dst_state_indices)}"
|
||||||
|
)
|
||||||
|
prefill_state_indices = prefill_state_indices[
|
||||||
|
: len(req.dst_state_indices)
|
||||||
|
]
|
||||||
# Reuse _send_kvcache_generic interface to send extra pool data
|
# Reuse _send_kvcache_generic interface to send extra pool data
|
||||||
prefill_state_indices = np.array(prefill_state_indices, dtype=np.int32)
|
prefill_state_indices = np.array(prefill_state_indices, dtype=np.int32)
|
||||||
dst_state_indices = np.array(req.dst_state_indices, dtype=np.int32)
|
dst_state_indices = np.array(req.dst_state_indices, dtype=np.int32)
|
||||||
|
|||||||
Reference in New Issue
Block a user