We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4de790f commit 5d96533Copy full SHA for 5d96533
vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py
@@ -739,7 +739,8 @@ def _read_blocks(
739
# just notify P worker that we have the blocks we need.
740
num_local_blocks = len(local_block_ids)
741
if num_local_blocks == 0:
742
- self.nixl_wrapper.send_notif(dst_engine_id,
+ agent_name = self._remote_agents[dst_engine_id]
743
+ self.nixl_wrapper.send_notif(agent_name,
744
notif_msg=request_id.encode("utf-8"))
745
return
746
0 commit comments