From fea0731cf45d4f0cf1622cde6ada570d8da4931f Mon Sep 17 00:00:00 2001 From: "rshaw@neuralmagic.com" Date: Fri, 27 Jun 2025 15:11:23 +0000 Subject: [PATCH] update Signed-off-by: rshaw@neuralmagic.com --- .../kv_transfer/kv_connector/v1/nixl_connector.py | 7 ------- 1 file changed, 7 deletions(-) diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py index 053901c1cc42d..5283c3e206eb8 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py @@ -974,17 +974,10 @@ class NixlConnectorWorker: remote_xfer_side_handle, remote_block_descs_ids, notif_msg=notif_id, - skip_desc_merge=True, # this causes the issue to emerge immediately. ) # Begin async xfer. - start = time.perf_counter() self.nixl_wrapper.transfer(handle) - end = time.perf_counter() - print(f"self.nixl_wrapper.transfer() TIME: {end-start}") - if end - start > 0.2: - print(f"{local_block_ids=}") - print(f"{remote_block_ids=}") # Use handle to check completion in future step(). # TODO (NickLucche) surface xfer elapsed time