[chore] update

Author: liyonghua0910

fastdeploy/engine/common_engine.py

@@ -140,10 +140,6 @@ def __init__(self, cfg: FDConfig, start_queue=True, use_async_llm=False):
         self.cfg = cfg
         self.use_async_llm = use_async_llm
 
-        # 为每个 DP 设置独立的 PROMETHEUS_MULTIPROC_DIR，避免多 DP 的 Counter/Histogram 指标混淆
-        if not envs.FD_ENABLE_MULTI_API_SERVER and self.cfg.parallel_config.data_parallel_size > 1:
-            setup_dp_prometheus_dir(self.cfg.parallel_config.local_data_parallel_id)
-
         if self.cfg.parallel_config.data_parallel_size > 1:
             self.llm_logger = get_logger(
                 "fastdeploy", f"fastdeploy_dprank{self.cfg.parallel_config.local_data_parallel_id}.log"
@@ -2763,10 +2759,13 @@ def launch_components(self):
                         f"Engine is initialized successfully with {self.cfg.parallel_config.tensor_parallel_size}"
                         + f" data parallel id {i}"
                     )
+                    setup_dp_prometheus_dir(i)
                     self.dp_processed[-1].start()
                     while self.launched_expert_service_signal.value[i] == 0:
                         time.sleep(1)
 
+                setup_dp_prometheus_dir(0)
+
     def check_worker_initialize_status(self):
         """
         Check the initlialize status of workers by stdout logging

fastdeploy/engine/engine.py

@@ -50,6 +50,7 @@
     log_request_error,
 )
 from fastdeploy.metrics.metrics import main_process_metrics
+from fastdeploy.metrics.prometheus_multiprocess_setup import setup_dp_prometheus_dir
 from fastdeploy.platforms import current_platform
 from fastdeploy.utils import EngineError, console_logger, envs, llm_logger
 
@@ -897,8 +898,11 @@ def launch_components(self):
                         f"Engine is initialized successfully with {self.cfg.parallel_config.tensor_parallel_size}"
                         + f" data parallel id {i}"
                     )
+                    setup_dp_prometheus_dir(i)
                     self.dp_processed[-1].start()
 
+                setup_dp_prometheus_dir(0)
+
                 for i in range(
                     1,
                     self.cfg.parallel_config.data_parallel_size // self.cfg.nnode,