From ff4569f135d1c9c98bcc6502581ad4ae5ca32a38 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=91=A8=E5=91=A8=E5=91=A8?= <39978853+zhoutianzi666@users.noreply.github.com> Date: Mon, 21 Jul 2025 22:44:57 +0800 Subject: [PATCH] remove some code in ep.py (#2947) --- fastdeploy/model_executor/layers/moe/ep.py | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/fastdeploy/model_executor/layers/moe/ep.py b/fastdeploy/model_executor/layers/moe/ep.py index 4595ec00c..16a015204 100644 --- a/fastdeploy/model_executor/layers/moe/ep.py +++ b/fastdeploy/model_executor/layers/moe/ep.py @@ -361,22 +361,6 @@ class EPDecoderRunner(EPRunner): return recv_hidden_states, recv_expert_count, handle def combine(self, ffn_out, topk_idx, topk_weights, handle): - # TODO(@wufeisheng): Delete them when deepep in PaddlePaddle is fixed - ( - src_info, - layout_range, - num_max_dispatch_tokens_per_rank, - num_experts, - ) = handle - - handle = ( - src_info, - layout_range, - num_max_dispatch_tokens_per_rank, - None, - num_experts, - ) - combined_hidden_states, combine_hook = self.ep_engine.low_latency_combine( ffn_out, topk_idx, topk_weights, handle )