From 7742eb6c5921cf5eb10d3c8fd3130628abcf2fba Mon Sep 17 00:00:00 2001 From: Robert Shaw Date: Tue, 9 Sep 2025 02:59:39 +0000 Subject: [PATCH] updated Signed-off-by: Robert Shaw --- vllm/v1/executor/multiproc_executor.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/vllm/v1/executor/multiproc_executor.py b/vllm/v1/executor/multiproc_executor.py index c3d6c20e22e2a..2af32c5eef368 100644 --- a/vllm/v1/executor/multiproc_executor.py +++ b/vllm/v1/executor/multiproc_executor.py @@ -641,7 +641,13 @@ class WorkerProc: def worker_busy_loop(self, cancel: Optional[threading.Event] = None): """Main busy loop for Multiprocessing Workers""" + import os + p = os.getpid() + i = 0 while True: + if i % 100 == 0: + logger.info("WorkerProc RSS MB: %d", p.memory_info().rss/1024/1024) + i += 1 method, args, kwargs, output_rank = self.rpc_broadcast_mq.dequeue( cancel=cancel) try: