WIP - more suppress of warnings.

Author: rani-pinchuk

Lib/test/test_concurrent_futures/test_as_completed.py

@@ -7,6 +7,7 @@
     CANCELLED_AND_NOTIFIED, FINISHED, Future)
 
 from test import support
+from test.support import warnings_helper
 
 from .util import (
     PENDING_FUTURE, RUNNING_FUTURE,
@@ -19,6 +20,7 @@ def mul(x, y):
 
 
 class AsCompletedTests:
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_no_timeout(self):
         future1 = self.executor.submit(mul, 2, 21)
         future2 = self.executor.submit(mul, 7, 6)
@@ -35,6 +37,7 @@ def test_no_timeout(self):
                  future1, future2]),
                 completed)
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_future_times_out(self):
         """Test ``futures.as_completed`` timing out before
         completing it's final future."""
@@ -62,6 +65,7 @@ def test_future_times_out(self):
                 # Check that ``future`` wasn't completed.
                 self.assertEqual(completed_futures, already_completed)
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_duplicate_futures(self):
         # Issue 20367. Duplicate futures should not raise exceptions or give
         # duplicate responses.

Lib/test/test_concurrent_futures/test_shutdown.py

@@ -6,6 +6,7 @@
 from concurrent import futures
 
 from test import support
+from test.support import warnings_helper
 from test.support.script_helper import assert_python_ok
 
 from .util import (
@@ -77,12 +78,14 @@ def run_last():
         self.assertIn("RuntimeError: cannot schedule new futures", err.decode())
         self.assertEqual(out.strip(), b"runtime-error")
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_hang_issue12364(self):
         fs = [self.executor.submit(time.sleep, 0.1) for _ in range(50)]
         self.executor.shutdown()
         for f in fs:
             f.result()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_cancel_futures(self):
         assert self.worker_count <= 5, "test needs few workers"
         fs = [self.executor.submit(time.sleep, .1) for _ in range(50)]
@@ -128,6 +131,7 @@ def test_hang_gh83386(self):
         self.assertFalse(err)
         self.assertEqual(out.strip(), b"apple")
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_hang_gh94440(self):
         """shutdown(wait=True) doesn't hang when a future was submitted and
         quickly canceled right before shutdown.
@@ -171,6 +175,7 @@ def acquire_lock(lock):
         for t in self.executor._threads:
             t.join()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_context_manager_shutdown(self):
         with futures.ThreadPoolExecutor(max_workers=5) as e:
             executor = e
@@ -180,6 +185,7 @@ def test_context_manager_shutdown(self):
         for t in executor._threads:
             t.join()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_del_shutdown(self):
         executor = futures.ThreadPoolExecutor(max_workers=5)
         res = executor.map(abs, range(-5, 5))
@@ -193,6 +199,7 @@ def test_del_shutdown(self):
         # executor got shutdown.
         assert all([r == abs(v) for r, v in zip(res, range(-5, 5))])
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_shutdown_no_wait(self):
         # Ensure that the executor cleans up the threads when calling
         # shutdown with wait=False
@@ -207,7 +214,7 @@ def test_shutdown_no_wait(self):
         # executor got shutdown.
         assert all([r == abs(v) for r, v in zip(res, range(-5, 5))])
 
-
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_thread_names_assigned(self):
         executor = futures.ThreadPoolExecutor(
             max_workers=5, thread_name_prefix='SpecialPool')
@@ -220,6 +227,7 @@ def test_thread_names_assigned(self):
             self.assertRegex(t.name, r'^SpecialPool_[0-4]$')
             t.join()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_thread_names_default(self):
         executor = futures.ThreadPoolExecutor(max_workers=5)
         executor.map(abs, range(-5, 5))
@@ -253,6 +261,7 @@ def test_cancel_futures_wait_false(self):
 
 
 class ProcessPoolShutdownTest(ExecutorShutdownTest):
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_processes_terminate(self):
         def acquire_lock(lock):
             lock.acquire()
@@ -276,6 +285,7 @@ def acquire_lock(lock):
         for p in processes.values():
             p.join()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_context_manager_shutdown(self):
         with futures.ProcessPoolExecutor(
                 max_workers=5, mp_context=self.get_context()) as e:
@@ -286,6 +296,7 @@ def test_context_manager_shutdown(self):
         for p in processes.values():
             p.join()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_del_shutdown(self):
         executor = futures.ProcessPoolExecutor(
                 max_workers=5, mp_context=self.get_context())
@@ -308,6 +319,7 @@ def test_del_shutdown(self):
         # executor got shutdown.
         assert all([r == abs(v) for r, v in zip(res, range(-5, 5))])
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_shutdown_no_wait(self):
         # Ensure that the executor cleans up the processes when calling
         # shutdown with wait=False