|
18 | 18 | show_filtered_argument_or_group_from_help)
|
19 | 19 | from vllm.logger import init_logger
|
20 | 20 | from vllm.usage.usage_lib import UsageContext
|
21 |
| -from vllm.utils import FlexibleArgumentParser, decorate_logs, get_tcp_uri |
| 21 | +from vllm.utils import (FlexibleArgumentParser, decorate_logs, get_tcp_uri, |
| 22 | + set_process_title) |
22 | 23 | from vllm.v1.engine.core import EngineCoreProc
|
23 | 24 | from vllm.v1.engine.utils import CoreEngineProcManager, launch_core_engines
|
24 | 25 | from vllm.v1.executor.abstract import Executor
|
@@ -74,7 +75,7 @@ def run_headless(args: argparse.Namespace):
|
74 | 75 |
|
75 | 76 | if args.api_server_count > 1:
|
76 | 77 | raise ValueError("api_server_count can't be set in headless mode")
|
77 |
| - # set_process_title("Headless_ProcManager") |
| 78 | + |
78 | 79 | # Create the EngineConfig.
|
79 | 80 | engine_args = vllm.AsyncEngineArgs.from_cli_args(args)
|
80 | 81 | usage_context = UsageContext.OPENAI_API_SERVER
|
@@ -139,8 +140,6 @@ def run_multi_api_server(args: argparse.Namespace):
|
139 | 140 |
|
140 | 141 | orig_disable_mm_preprocessor_cache = args.disable_mm_preprocessor_cache
|
141 | 142 |
|
142 |
| - # set_process_title("ProcManager") |
143 |
| - |
144 | 143 | if num_api_servers > 1:
|
145 | 144 | setup_multiprocess_prometheus()
|
146 | 145 |
|
@@ -225,7 +224,9 @@ def run_api_server_worker_proc(listen_address,
|
225 | 224 | **uvicorn_kwargs) -> None:
|
226 | 225 | """Entrypoint for individual API server worker processes."""
|
227 | 226 |
|
228 |
| - # Add process-specific prefix to stdout and stderr. |
| 227 | + # Set process title and add process-specific prefix to stdout and stderr. |
| 228 | + server_index = client_config.get("client_index", 0) if client_config else 0 |
| 229 | + set_process_title("APIServer", str(server_index)) |
229 | 230 | decorate_logs()
|
230 | 231 |
|
231 | 232 | uvloop.run(
|
|
0 commit comments