diff --git a/vllm/v1/engine/coordinator.py b/vllm/v1/engine/coordinator.py index 0d07f29a5..28cd13758 100644 --- a/vllm/v1/engine/coordinator.py +++ b/vllm/v1/engine/coordinator.py @@ -248,9 +248,9 @@ class DPCoordinatorProc: # Subscription message, on the other hand, is sent # by each engine during initialization publish_back.send(b"READY") - else: + elif buffer != b"\x00": logger.error( - "DP Coordinator receives unexpected message from engines" + "DP Coordinator received unexpected message from engines" ) if publish_front in events: