WIP - adding more suppressing of the DeprecatinoWarning

Author: rani-pinchuk

Lib/test/test_concurrent_futures/executor.py

@@ -77,6 +77,7 @@ def test_map_exception(self):
         with self.assertRaises(ZeroDivisionError):
             i.__next__()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     @support.requires_resource('walltime')
     def test_map_timeout(self):
         results = []
@@ -135,6 +136,7 @@ def test_map_buffersize_on_infinite_iterable(self):
         self.assertEqual(next(res, None), "1")
         self.assertEqual(next(res, None), "2")
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_map_buffersize_on_multiple_infinite_iterables(self):
         res = self.executor.map(
             add,

Lib/test/test_concurrent_futures/test_wait.py

@@ -3,7 +3,7 @@
 import unittest
 from concurrent import futures
 from test import support
-from test.support import threading_helper
+from test.support import threading_helper, warnings_helper
 
 from .util import (
     CANCELLED_FUTURE, CANCELLED_AND_NOTIFIED_FUTURE, EXCEPTION_FUTURE,
@@ -22,6 +22,7 @@ def wait_and_raise(e):
 
 
 class WaitTests:
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_20369(self):
         # See https://bugs.python.org/issue20369
         future = self.executor.submit(mul, 1, 2)
@@ -30,7 +31,7 @@ def test_20369(self):
         self.assertEqual({future}, done)
         self.assertEqual(set(), not_done)
 
-
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_first_completed(self):
         event = self.create_event()
         future1 = self.executor.submit(mul, 21, 2)
@@ -47,6 +48,7 @@ def test_first_completed(self):
             event.set()
         future2.result()  # wait for job to finish
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_first_completed_some_already_completed(self):
         event = self.create_event()
         future1 = self.executor.submit(event.wait)
@@ -64,6 +66,7 @@ def test_first_completed_some_already_completed(self):
             event.set()
         future1.result()  # wait for job to finish
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_first_exception(self):
         event1 = self.create_event()
         event2 = self.create_event()
@@ -93,6 +96,7 @@ def wait_for_future1():
             event2.set()
         future3.result()  # wait for job to finish
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_first_exception_some_already_complete(self):
         event = self.create_event()
         future1 = self.executor.submit(divmod, 21, 0)
@@ -114,6 +118,7 @@ def test_first_exception_some_already_complete(self):
             event.set()
         future2.result()  # wait for job to finish
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_first_exception_one_already_failed(self):
         event = self.create_event()
         future1 = self.executor.submit(event.wait)
@@ -129,6 +134,7 @@ def test_first_exception_one_already_failed(self):
             event.set()
         future1.result()  # wait for job to finish
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_all_completed(self):
         future1 = self.executor.submit(divmod, 2, 0)
         future2 = self.executor.submit(mul, 2, 21)
@@ -148,6 +154,7 @@ def test_all_completed(self):
                               future2]), finished)
         self.assertEqual(set(), pending)
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     def test_timeout(self):
         short_timeout = 0.050
 

Lib/test/test_logging.py

@@ -4046,6 +4046,7 @@ def test_config_queue_handler_invalid_config_does_not_create_multiprocessing_man
                 self._apply_simple_queue_listener_configuration(qspec)
                 manager.assert_not_called()
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     @skip_if_tsan_fork
     @support.requires_subprocess()
     @unittest.skipUnless(support.Py_DEBUG, "requires a debug build for testing"
@@ -4109,6 +4110,7 @@ def _mpinit_issue121723(qspec, message_to_log):
         # log a message (this creates a record put in the queue)
         logging.getLogger().info(message_to_log)
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     @skip_if_tsan_fork
     @support.requires_subprocess()
     def test_multiprocessing_queues(self):
@@ -5339,6 +5341,7 @@ def _extract_logrecord_process_name(key, logMultiprocessing, conn=None):
         else:
             return results
 
+    @warnings_helper.ignore_warnings(category=DeprecationWarning)  # gh-135427
     @skip_if_tsan_fork
     def test_multiprocessing(self):
         support.skip_if_broken_multiprocessing_synchronize()