File tree Expand file tree Collapse file tree 1 file changed +10
-4
lines changed
vllm/distributed/device_communicators Expand file tree Collapse file tree 1 file changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -357,8 +357,11 @@ def acquire_write(self, timeout: Optional[float] = None):
357357 # if we wait for a long time, log a message
358358 if (time .monotonic () - start_time
359359 > VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning ):
360- logger .debug ("No available block found in %s second. " ,
361- VLLM_RINGBUFFER_WARNING_INTERVAL )
360+ logger .debug (
361+ ("No available shared memory broadcast block found"
362+ " in %s second." ),
363+ VLLM_RINGBUFFER_WARNING_INTERVAL ,
364+ )
362365 n_warning += 1
363366
364367 # if we time out, raise an exception
@@ -415,8 +418,11 @@ def acquire_read(self, timeout: Optional[float] = None):
415418 # if we wait for a long time, log a message
416419 if (time .monotonic () - start_time
417420 > VLLM_RINGBUFFER_WARNING_INTERVAL * n_warning ):
418- logger .debug ("No available block found in %s second. " ,
419- VLLM_RINGBUFFER_WARNING_INTERVAL )
421+ logger .debug (
422+ ("No available shared memory broadcast block found"
423+ "in %s second." ),
424+ VLLM_RINGBUFFER_WARNING_INTERVAL ,
425+ )
420426 n_warning += 1
421427
422428 # if we time out, raise an exception
You can’t perform that action at this time.
0 commit comments