@@ -694,23 +694,23 @@ def test_map_workerid_to_index():
694694
695695 zero_resource_list = []
696696 index_list = ResourceManager .get_index_list (num_workers , num_rsets , zero_resource_list )
697- for workerID in range (0 , num_workers ):
698- index = index_list [workerID ]
699- assert index == workerID , "index incorrect. Received: " + str (index )
700-
701- zero_resource_list = [0 ]
702- index_list = ResourceManager .get_index_list (num_workers , num_rsets , zero_resource_list )
703- for workerID in range (1 , num_workers ):
704- index = index_list [workerID ]
697+ for workerID in range (1 , num_workers + 1 ):
698+ index = index_list [workerID - 1 ]
705699 assert index == workerID - 1 , "index incorrect. Received: " + str (index )
706700
707- zero_resource_list = [0 , 1 ]
701+ zero_resource_list = [1 ]
708702 index_list = ResourceManager .get_index_list (num_workers , num_rsets , zero_resource_list )
709- for workerID in range (2 , num_workers ):
710- index = index_list [workerID ]
703+ for workerID in range (2 , num_workers + 1 ):
704+ index = index_list [workerID - 1 ]
711705 assert index == workerID - 2 , "index incorrect. Received: " + str (index )
712706
713- zero_resource_list = [0 , 2 ]
707+ zero_resource_list = [1 , 2 ]
708+ index_list = ResourceManager .get_index_list (num_workers , num_rsets , zero_resource_list )
709+ for workerID in range (3 , num_workers + 1 ):
710+ index = index_list [workerID - 1 ]
711+ assert index == workerID - 3 , "index incorrect. Received: " + str (index )
712+
713+ zero_resource_list = [1 , 3 ]
714714 index_list = ResourceManager .get_index_list (num_workers , num_rsets , zero_resource_list )
715715
716716 workerID = 2
0 commit comments