@@ -443,7 +443,7 @@ def test_execute_task_failed_no_argument(self):
443443 q .put ({"fn" : calc_array , "args" : (), "kwargs" : {}, "future" : f })
444444 q .put ({"shutdown" : True , "wait" : True })
445445 cloudpickle_register (ind = 1 )
446- execute_tasks (
446+ execute_multiple_tasks (
447447 future_queue = q ,
448448 cores = 1 ,
449449 openmpi_oversubscribe = False ,
@@ -459,7 +459,7 @@ def test_execute_task_failed_wrong_argument(self):
459459 q .put ({"fn" : calc_array , "args" : (), "kwargs" : {"j" : 4 }, "future" : f })
460460 q .put ({"shutdown" : True , "wait" : True })
461461 cloudpickle_register (ind = 1 )
462- execute_tasks (
462+ execute_multiple_tasks (
463463 future_queue = q ,
464464 cores = 1 ,
465465 openmpi_oversubscribe = False ,
@@ -535,7 +535,7 @@ def test_execute_task_cache_failed_no_argument(self):
535535 q .put ({"fn" : calc_array , "args" : (), "kwargs" : {}, "future" : f })
536536 q .put ({"shutdown" : True , "wait" : True })
537537 cloudpickle_register (ind = 1 )
538- execute_tasks (
538+ execute_multiple_tasks (
539539 future_queue = q ,
540540 cores = 1 ,
541541 openmpi_oversubscribe = False ,
0 commit comments