Signed-off-by: yewentao256 <zhyanwentao@126.com>
This commit is contained in:
yewentao256 2025-10-14 07:37:37 -07:00
parent 3967657957
commit 8d8c88ec87
2 changed files with 2 additions and 1 deletions

View File

@ -1137,7 +1137,7 @@ class FusedMoE(CustomOp):
)
self.local_num_experts = local_num_experts
self.register_buffer("expert_map", expert_map)
logger.debug_once(
logger.info_once(
"[EP Rank %s/%s] Expert parallelism is enabled. Expert "
"placement strategy: %s. Local/global"
" number of experts: %s/%s. Experts local to global index map:"

View File

@ -725,6 +725,7 @@ class EngineCoreProc(EngineCore):
)
# Receive initialization message.
logger.debug("Waiting for init message from front-end.")
if not handshake_socket.poll(timeout=HANDSHAKE_TIMEOUT_MINS * 60_000):
raise RuntimeError(
"Did not receive response from front-end "