Skip to content

Commit d2d633b

Browse files
allow parallel dp starting (#7426)
1 parent 420a8c1 commit d2d633b

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

fastdeploy/engine/engine.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -876,8 +876,14 @@ def launch_components(self):
876876
+ f" data parallel id {i}"
877877
)
878878
self.dp_processed[-1].start()
879+
880+
for i in range(
881+
1,
882+
self.cfg.parallel_config.data_parallel_size // self.cfg.nnode,
883+
):
884+
879885
while self.launched_expert_service_signal.value[i] == 0:
880-
time.sleep(1)
886+
time.sleep(0.1)
881887

882888
def check_worker_initialize_status(self):
883889
"""

0 commit comments

Comments
 (0)