@@ -301,19 +301,14 @@ def generate_refined_tasks(base_output_dir, current_pass_id):
301301 print (f"[Init] Resuming from Pass_{ current_pass_id - 1 } (Dir: { prev_pass_dir } )..." )
302302
303303 prev_config = DecomposeConfig .load (prev_pass_dir )
304- prev_incorrect_subgraphs = prev_config .incorrect_models
305- prev_tasks_map = prev_config .tasks_map
306- running_states = prev_config .running_states
307-
308- # Load previous max size as fallback
309- prev_max_subgraph_size = prev_config .max_subgraph_size
310- max_subgraph_size = prev_max_subgraph_size // 2
311-
312- if not prev_incorrect_subgraphs :
313- return {}, max_subgraph_size , running_states
304+ max_subgraph_size = prev_config .max_subgraph_size // 2
305+ if not prev_config .incorrect_models :
306+ return {}, max_subgraph_size , prev_config .running_states
314307
315308 tasks_map = {}
316- for subgraph_path in prev_incorrect_subgraphs :
309+ prev_tasks_map = prev_config .tasks_map
310+
311+ for subgraph_path in prev_config .incorrect_models :
317312 # Parse model name and subgraph index
318313 model_name_with_subgraph_idx = subgraph_path .rstrip ("/" ).split (os .sep )[- 1 ]
319314 model_name = "_" .join (model_name_with_subgraph_idx .split ("_" )[:- 1 ])
@@ -336,7 +331,7 @@ def generate_refined_tasks(base_output_dir, current_pass_id):
336331 "split_positions" : set (),
337332 }
338333
339- return tasks_map , max_subgraph_size , running_states
334+ return tasks_map , max_subgraph_size , prev_config . running_states
340335
341336
342337def prepare_tasks_and_verify (args , current_pass_id , base_output_dir ):
0 commit comments