File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -131,7 +131,7 @@ def forward_before(self):
131
131
self .eplb_loader .asyn_expert_weight_transfer (self .reqs )
132
132
133
133
def forward_end (self , dummy_run = False ):
134
- self .adaptor .get_rank_expert_workload (self .num_moe_layers )
134
+ self .adaptor .get_rank_expert_workload (self .num_moe_layers , dummy_run )
135
135
if not self .update_in_flight and self .get_update_iteration ():
136
136
moe_load = self .compute_and_set_moe_load (dummy_run )
137
137
self .wakeup_eplb_worker ()
@@ -144,8 +144,8 @@ def forward_end(self, dummy_run=False):
144
144
145
145
self .eplb_loader .update_expert_map_and_weight (self .reqs , self .redundant_enable )
146
146
147
- def compute_and_set_moe_load (self ):
148
- local_load = self .adaptor .get_rank_expert_workload (self .num_moe_layers )
147
+ def compute_and_set_moe_load (self , dummy_run = False ):
148
+ local_load = self .adaptor .get_rank_expert_workload (self .num_moe_layers , dummy_run )
149
149
self ._gather_buffer = None
150
150
if dist .is_initialized ():
151
151
self .world_size = dist .get_world_size ()
You can’t perform that action at this time.
0 commit comments