Skip to content

Commit 2ac5d72

Browse files
committed
fix
1 parent 7130a8e commit 2ac5d72

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lightllm/server/httpserver_for_pd_master/pd_selector/pd_selector.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,10 +44,12 @@ def __init__(self, prefill_nodes: List[PD_Client_Obj], decode_nodes: List[PD_Cli
4444
def select_p_d_node(
4545
self, prompt: Union[str, List[int]], sampling_params: SamplingParams, multimodal_params: MultimodalParams
4646
) -> Tuple[PD_Client_Obj, PD_Client_Obj]:
47+
self.prefill_node_index = self.prefill_node_index % len(self.prefill_nodes)
48+
self.decode_node_index = self.decode_node_index % len(self.decode_nodes)
4749
p_node = self.prefill_nodes[self.prefill_node_index]
4850
d_node = self.decode_nodes[self.decode_node_index]
49-
self.prefill_node_index = (self.prefill_node_index + 1) % len(self.prefill_nodes)
50-
self.decode_node_index = (self.decode_node_index + 1) % len(self.decode_nodes)
51+
self.prefill_node_index += 1
52+
self.decode_node_index += 1
5153
return p_node, d_node
5254

5355

0 commit comments

Comments
 (0)