@@ -254,7 +254,7 @@ def test_force_shutdown_workers_invalid_op(self):
254254 operation = 'invalid operation' ),
255255
256256 @parameterize (* FORCE_SHUTDOWN_PARAMS )
257- def test_terminate_kill_workers (self , function_name ):
257+ def test_force_shutdown_workers (self , function_name ):
258258 manager = self .get_context ().Manager ()
259259 q = manager .Queue ()
260260
@@ -279,7 +279,7 @@ def test_terminate_kill_workers(self, function_name):
279279 self .assertRaises (queue .Empty , q .get , timeout = 1 )
280280
281281 @parameterize (* FORCE_SHUTDOWN_PARAMS )
282- def test_terminate_kill_workers_dead_workers (self , function_name ):
282+ def test_force_shutdown_workers_dead_workers (self , function_name ):
283283 with futures .ProcessPoolExecutor (max_workers = 1 ) as executor :
284284 future = executor .submit (os ._exit , 1 )
285285 self .assertRaises (BrokenProcessPool , future .result )
@@ -288,7 +288,7 @@ def test_terminate_kill_workers_dead_workers(self, function_name):
288288 getattr (executor , function_name )()
289289
290290 @parameterize (* FORCE_SHUTDOWN_PARAMS )
291- def test_terminate_kill_workers_not_started_yet (self , function_name ):
291+ def test_force_shutdown_workers_not_started_yet (self , function_name ):
292292 ctx = self .get_context ()
293293 with unittest .mock .patch .object (ctx , 'Process' ) as mock_process :
294294 with futures .ProcessPoolExecutor (max_workers = 1 , mp_context = ctx ) as executor :
@@ -300,7 +300,7 @@ def test_terminate_kill_workers_not_started_yet(self, function_name):
300300 mock_process .return_value .terminate .assert_not_called ()
301301
302302 @parameterize (* FORCE_SHUTDOWN_PARAMS )
303- def test_terminate_kill_workers_stops_pool (self , function_name ):
303+ def test_force_shutdown_workers_stops_pool (self , function_name ):
304304 with futures .ProcessPoolExecutor (max_workers = 1 ) as executor :
305305 task = executor .submit (time .sleep , 0 )
306306 self .assertIsNone (task .result ())
0 commit comments