diff --git a/Lib/test/test_concurrent_futures/executor.py b/Lib/test/test_concurrent_futures/executor.py index e64b9651cb9ba1..034178844e0f1a 100644 --- a/Lib/test/test_concurrent_futures/executor.py +++ b/Lib/test/test_concurrent_futures/executor.py @@ -72,9 +72,7 @@ def test_map_timeout(self): self.assertEqual([None, None], results) def test_map_args(self): - with self.assertRaisesRegex( - ValueError, "buffersize must be None or >= 1." - ): + with self.assertRaisesRegex(ValueError, "buffersize must be None or >= 1."): self.executor.map(bool, [], buffersize=0) with self.assertRaisesRegex( ValueError, "cannot specify both buffersize and timeout." @@ -82,10 +80,8 @@ def test_map_args(self): self.executor.map(bool, [], timeout=1, buffersize=1) def test_map_infinite_iterable(self): - self.assertEqual( - next(iter(self.executor.map(str, itertools.count(1), buffersize=1))), - "1", - ) + results = self.executor.map(str, itertools.count(1), buffersize=1) + self.assertEqual(next(iter(results)), "1") def test_map_buffersize(self): manager = Manager() @@ -113,8 +109,6 @@ def test_map_buffersize(self): set(range(min(buffersize + 1, iterable_size))), ) - - def test_shutdown_race_issue12456(self): # Issue #12456: race condition at shutdown where trying to post a # sentinel in the call queue blocks (the queue is full while processes