File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 3
3
import math
4
4
import threading
5
5
import time
6
- from collections .abc import Iterator
7
6
from collections import defaultdict
7
+ from collections .abc import Iterator
8
8
from concurrent .futures import ThreadPoolExecutor
9
9
from dataclasses import dataclass
10
10
from enum import Enum
@@ -827,8 +827,7 @@ def _read_blocks(
827
827
raise RuntimeError (
828
828
"LLMDataDistCMgrConnectorWorker: Timeout during pull_blocks, you can try to increase the sync_kv_timeout config or checking your connect status"
829
829
)
830
- self .send_finish_to_remote (remote_ip , remote_port + tp_offset ,
831
- request_id )
830
+ self .send_finish_to_remote (remote_ip , remote_port , request_id )
832
831
with self .thread_lock :
833
832
self .finished_reqs .add (request_id )
834
833
You can’t perform that action at this time.
0 commit comments