There was an error while loading. Please reload this page.
1 parent b3c18bf commit 89c355aCopy full SHA for 89c355a
1 file changed
Lib/test/test_concurrent_futures/test_process_pool.py
@@ -270,15 +270,18 @@ def test_force_shutdown_workers(self, function_name):
270
self.assertEqual(q.get(timeout=5), 'started')
271
272
worker_process = list(executor._processes.values())[0]
273
+
274
+ Mock = unittest.mock.Mock
275
+ worker_process.terminate = Mock(wraps=worker_process.terminate)
276
+ worker_process.kill = Mock(wraps=worker_process.kill)
277
278
getattr(executor, function_name)()
279
worker_process.join()
280
- if function_name == TERMINATE_WORKERS or \
- sys.platform == 'win32':
- # On windows, kill and terminate both send SIGTERM
- self.assertEqual(worker_process.exitcode, -signal.SIGTERM)
281
+ if function_name == TERMINATE_WORKERS:
282
+ worker_process.terminate.assert_called()
283
elif function_name == KILL_WORKERS:
- self.assertEqual(worker_process.exitcode, -signal.SIGKILL)
284
+ worker_process.kill.assert_called()
285
else:
286
self.fail(f"Unknown operation: {function_name}")
287
0 commit comments