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 c6de8a7 commit a603307Copy full SHA for a603307
fastdeploy/engine/engine.py
@@ -605,7 +605,6 @@ def launch_components(self):
605
1,
606
self.cfg.parallel_config.data_parallel_size // self.cfg.nnode,
607
):
608
- time.sleep(3)
609
self.dp_processed.append(
610
multiprocessing.Process(
611
target=start_data_parallel_service,
@@ -620,9 +619,9 @@ def launch_components(self):
620
619
+ f" data parallel id {i}"
621
)
622
self.dp_processed[-1].start()
623
- for i in range(1, self.cfg.parallel_config.data_parallel_size // self.cfg.nnode):
624
- while self.launched_expert_service_signal.value[i] == 0:
625
- time.sleep(10)
+ while self.launched_expert_service_signal.value[i] == 0:
+ time.sleep(1)
+
626
627
def check_worker_initialize_status(self):
628
"""
0 commit comments