@@ -443,13 +443,13 @@ 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 (
447+ future_queue = q ,
448+ cores = 1 ,
449+ openmpi_oversubscribe = False ,
450+ spawner = MpiExecSpawner ,
451+ )
446452 with self .assertRaises (TypeError ):
447- execute_tasks (
448- future_queue = q ,
449- cores = 1 ,
450- openmpi_oversubscribe = False ,
451- spawner = MpiExecSpawner ,
452- )
453453 f .result ()
454454 q .join ()
455455
@@ -459,13 +459,13 @@ 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 (
463+ future_queue = q ,
464+ cores = 1 ,
465+ openmpi_oversubscribe = False ,
466+ spawner = MpiExecSpawner ,
467+ )
462468 with self .assertRaises (TypeError ):
463- execute_tasks (
464- future_queue = q ,
465- cores = 1 ,
466- openmpi_oversubscribe = False ,
467- spawner = MpiExecSpawner ,
468- )
469469 f .result ()
470470 q .join ()
471471
0 commit comments