Commit 388c8c20 authored by Victor Stinner's avatar Victor Stinner Committed by GitHub

bpo-35424: test_multiprocessing: join 3 pools (GH-10986)

Join 3 pools in these tests:

* test.test_multiprocessing_spawn.WithProcessesTestPool.test_context
* test.test_multiprocessing_spawn.WithProcessesTestPool.test_traceback
parent 3ffa8b9b
...@@ -2471,6 +2471,7 @@ class _TestPool(BaseTestCase): ...@@ -2471,6 +2471,7 @@ class _TestPool(BaseTestCase):
with self.Pool(2) as p: with self.Pool(2) as p:
r = p.map_async(sqr, L) r = p.map_async(sqr, L)
self.assertEqual(r.get(), expected) self.assertEqual(r.get(), expected)
p.join()
self.assertRaises(ValueError, p.map_async, sqr, L) self.assertRaises(ValueError, p.map_async, sqr, L)
@classmethod @classmethod
...@@ -2488,6 +2489,7 @@ class _TestPool(BaseTestCase): ...@@ -2488,6 +2489,7 @@ class _TestPool(BaseTestCase):
exc = e exc = e
else: else:
self.fail('expected RuntimeError') self.fail('expected RuntimeError')
p.join()
self.assertIs(type(exc), RuntimeError) self.assertIs(type(exc), RuntimeError)
self.assertEqual(exc.args, (123,)) self.assertEqual(exc.args, (123,))
cause = exc.__cause__ cause = exc.__cause__
...@@ -2512,6 +2514,7 @@ class _TestPool(BaseTestCase): ...@@ -2512,6 +2514,7 @@ class _TestPool(BaseTestCase):
self.fail('expected SayWhenError') self.fail('expected SayWhenError')
self.assertIs(type(exc), SayWhenError) self.assertIs(type(exc), SayWhenError)
self.assertIs(exc.__cause__, None) self.assertIs(exc.__cause__, None)
p.join()
@classmethod @classmethod
def _test_wrapped_exception(cls): def _test_wrapped_exception(cls):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment