fix

Author: hiworldwzj

lightllm/server/api_cli.py

@@ -10,7 +10,7 @@ def make_argument_parser() -> argparse.ArgumentParser:
         choices=["normal", "prefill", "decode", "pd_master", "config_server"],
         default="normal",
         help="""set run mode, normal is started for a single server, prefill decode pd_master is for pd split run mode,
-                config_server is for pd split mode used to register pd_master node, and get pd_master node list, 
+                config_server is for pd split mode used to register pd_master node, and get pd_master node list,
                 specifically designed for large-scale, high-concurrency scenarios where `pd_master` encounters
                 significant CPU bottlenecks.""",
     )

lightllm/server/config_server/__init__.py

@@ -1,12 +1,12 @@
 """
-This module implements a configuration service designed to facilitate the 
-registration and retrieval of information in a PD separation mode. It 
+This module implements a configuration service designed to facilitate the
+registration and retrieval of information in a PD separation mode. It
 allows various nodes to register their own information and query global
  configuration details efficiently.
 
 Key Features:
 - Node registration: Enables nodes to register their specific information.
-- Global configuration query: Provides mechanisms for querying shared 
+- Global configuration query: Provides mechanisms for querying shared
     configuration data across the system.
 - Designed for distributed systems operating in PD separation mode.
 """

lightllm/server/httpserver_for_pd_master/register_loop.py

@@ -2,7 +2,6 @@
 import pickle
 import websockets
 import socket
-import pickle
 from lightllm.utils.net_utils import get_hostname_ip
 from lightllm.utils.log_utils import init_logger
 from lightllm.server.httpserver_for_pd_master.manager import HttpServerManagerForPDMaster

lightllm/server/req_id_generator.py

@@ -37,7 +37,8 @@ def _check_and_set_new_id_range(self):
             else:
                 while True:
                     try:
-                        url = f"http://{self.args.config_server_host}:{self.args.config_server_port}/allocate_global_unique_id_range"
+                        config_server_ip_port = f"{self.args.config_server_host}:{self.args.config_server_port}"
+                        url = f"http://{config_server_ip_port}/allocate_global_unique_id_range"
                         response = requests.get(url)
                         if response.status_code == 200:
                             id_range = response.json()