diff --git a/vllm/distributed/device_communicators/shm_broadcast.py b/vllm/distributed/device_communicators/shm_broadcast.py index 842d9edfd1c55..0d54fc73c882b 100644 --- a/vllm/distributed/device_communicators/shm_broadcast.py +++ b/vllm/distributed/device_communicators/shm_broadcast.py @@ -357,8 +357,11 @@ class MessageQueue: # if we wait for a long time, log a message if (time.monotonic() - start_time > VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning): - logger.debug("No available block found in %s second. ", - VLLM_RINGBUFFER_WARNING_INTERVAL) + logger.debug( + ("No available shared memory broadcast block found" + " in %s second."), + VLLM_RINGBUFFER_WARNING_INTERVAL, + ) n_warning += 1 # if we time out, raise an exception @@ -415,8 +418,11 @@ class MessageQueue: # if we wait for a long time, log a message if (time.monotonic() - start_time > VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning): - logger.debug("No available block found in %s second. ", - VLLM_RINGBUFFER_WARNING_INTERVAL) + logger.debug( + ("No available shared memory broadcast block found" + "in %s second."), + VLLM_RINGBUFFER_WARNING_INTERVAL, + ) n_warning += 1 # if we time out, raise an exception