https://github.com/python/cpython/commit/5221d9ce0e2beb0fe04bed072e1bb448fd522882
commit: 5221d9ce0e2beb0fe04bed072e1bb448fd522882
branch: main
author: Sam Gross <colesb...@gmail.com>
committer: colesbury <colesb...@gmail.com>
date: 2025-03-01T17:22:13Z
summary:
Revert "gh-128364: Fix flaky `test_timeout` test (gh-130724)" (gh-130732)
Change broke Android and iOS buildbots that do not have multiprocessing.
This reverts commit cfa0b1dc375e63cde28e61a47108c645b0e74834.
files:
M Lib/test/test_concurrent_futures/test_wait.py
M Lib/test/test_concurrent_futures/util.py
diff --git a/Lib/test/test_concurrent_futures/test_wait.py
b/Lib/test/test_concurrent_futures/test_wait.py
index 697285779510a9..108cf54bf79e6f 100644
--- a/Lib/test/test_concurrent_futures/test_wait.py
+++ b/Lib/test/test_concurrent_futures/test_wait.py
@@ -114,8 +114,9 @@ def test_all_completed(self):
def test_timeout(self):
short_timeout = 0.050
+ long_timeout = short_timeout * 10
- future = self.executor.submit(self.event.wait)
+ future = self.executor.submit(time.sleep, long_timeout)
finished, pending = futures.wait(
[CANCELLED_AND_NOTIFIED_FUTURE,
@@ -131,9 +132,6 @@ def test_timeout(self):
finished)
self.assertEqual(set([future]), pending)
- # Set the event to allow the future to complete
- self.event.set()
-
class ThreadPoolWaitTests(ThreadPoolMixin, WaitTests, BaseTestCase):
diff --git a/Lib/test/test_concurrent_futures/util.py
b/Lib/test/test_concurrent_futures/util.py
index 4e9e4ef1daec03..44086217f9dbcb 100644
--- a/Lib/test/test_concurrent_futures/util.py
+++ b/Lib/test/test_concurrent_futures/util.py
@@ -1,6 +1,5 @@
import multiprocessing
import sys
-import threading
import time
import unittest
from concurrent import futures
@@ -47,14 +46,11 @@ def setUp(self):
self.t1 = time.monotonic()
if hasattr(self, "ctx"):
- self.manager = multiprocessing.Manager()
- self.event = self.manager.Event()
self.executor = self.executor_type(
max_workers=self.worker_count,
mp_context=self.get_context(),
**self.executor_kwargs)
else:
- self.event = threading.Event()
self.executor = self.executor_type(
max_workers=self.worker_count,
**self.executor_kwargs)
@@ -62,9 +58,6 @@ def setUp(self):
def tearDown(self):
self.executor.shutdown(wait=True)
self.executor = None
- if hasattr(self, "ctx"):
- self.manager.shutdown()
- self.manager = None
dt = time.monotonic() - self.t1
if support.verbose:
_______________________________________________
Python-checkins mailing list -- python-checkins@python.org
To unsubscribe send an email to python-checkins-le...@python.org
https://mail.python.org/mailman3/lists/python-checkins.python.org/
Member address: arch...@mail-archive.com
