diff --git a/vllm/v1/executor/multiproc_executor.py b/vllm/v1/executor/multiproc_executor.py index 2af32c5eef368..78ee881f33a5c 100644 --- a/vllm/v1/executor/multiproc_executor.py +++ b/vllm/v1/executor/multiproc_executor.py @@ -641,8 +641,8 @@ class WorkerProc: def worker_busy_loop(self, cancel: Optional[threading.Event] = None): """Main busy loop for Multiprocessing Workers""" - import os - p = os.getpid() + import os, psutil + p = psutil.Process(os.getpid()) i = 0 while True: if i % 100 == 0: