https://github.com/python/cpython/commit/5892853fb71acd6530e1e241a9a4bcf71a61fb21
commit: 5892853fb71acd6530e1e241a9a4bcf71a61fb21
branch: main
author: Kumar Aditya <[email protected]>
committer: kumaraditya303 <[email protected]>
date: 2024-12-18T11:35:29+05:30
summary:
gh-127949: deprecate `asyncio.set_event_loop_policy` (#128024)
First step towards deprecating the asyncio policy system.
This deprecates `asyncio.set_event_loop_policy` and will be removed in Python
3.16.
files:
M Doc/library/asyncio-policy.rst
M Lib/asyncio/events.py
M Lib/test/libregrtest/save_env.py
M Lib/test/test_asyncgen.py
M Lib/test/test_asyncio/test_base_events.py
M Lib/test/test_asyncio/test_buffered_proto.py
M Lib/test/test_asyncio/test_context.py
M Lib/test/test_asyncio/test_eager_task_factory.py
M Lib/test/test_asyncio/test_events.py
M Lib/test/test_asyncio/test_futures.py
M Lib/test/test_asyncio/test_futures2.py
M Lib/test/test_asyncio/test_locks.py
M Lib/test/test_asyncio/test_pep492.py
M Lib/test/test_asyncio/test_proactor_events.py
M Lib/test/test_asyncio/test_protocols.py
M Lib/test/test_asyncio/test_queues.py
M Lib/test/test_asyncio/test_runners.py
M Lib/test/test_asyncio/test_selector_events.py
M Lib/test/test_asyncio/test_sendfile.py
M Lib/test/test_asyncio/test_server.py
M Lib/test/test_asyncio/test_sock_lowlevel.py
M Lib/test/test_asyncio/test_ssl.py
M Lib/test/test_asyncio/test_sslproto.py
M Lib/test/test_asyncio/test_staggered.py
M Lib/test/test_asyncio/test_streams.py
M Lib/test/test_asyncio/test_subprocess.py
M Lib/test/test_asyncio/test_taskgroups.py
M Lib/test/test_asyncio/test_tasks.py
M Lib/test/test_asyncio/test_threads.py
M Lib/test/test_asyncio/test_timeouts.py
M Lib/test/test_asyncio/test_transports.py
M Lib/test/test_asyncio/test_unix_events.py
M Lib/test/test_asyncio/test_waitfor.py
M Lib/test/test_asyncio/test_windows_events.py
M Lib/test/test_asyncio/test_windows_utils.py
M Lib/test/test_builtin.py
M Lib/test/test_concurrent_futures/test_interpreter_pool.py
M Lib/test/test_contextlib_async.py
M Lib/test/test_coroutines.py
M Lib/test/test_inspect/test_inspect.py
M Lib/test/test_logging.py
M Lib/test/test_os.py
M Lib/test/test_pdb.py
M Lib/test/test_sys_settrace.py
M Lib/test/test_unittest/test_async_case.py
M Lib/test/test_unittest/testmock/testasync.py
diff --git a/Doc/library/asyncio-policy.rst b/Doc/library/asyncio-policy.rst
index 09b75762ff0272..e8e470c1b343fd 100644
--- a/Doc/library/asyncio-policy.rst
+++ b/Doc/library/asyncio-policy.rst
@@ -46,6 +46,10 @@ for the current process:
If *policy* is set to ``None``, the default policy is restored.
+ .. deprecated:: next
+ The :func:`set_event_loop_policy` function is deprecated and
+ will be removed in Python 3.16.
+
.. _asyncio-policy-objects:
diff --git a/Lib/asyncio/events.py b/Lib/asyncio/events.py
index ca0a4f2fee5840..0926cfe2323478 100644
--- a/Lib/asyncio/events.py
+++ b/Lib/asyncio/events.py
@@ -8,7 +8,9 @@
'AbstractEventLoopPolicy',
'AbstractEventLoop', 'AbstractServer',
'Handle', 'TimerHandle',
- 'get_event_loop_policy', 'set_event_loop_policy',
+ 'get_event_loop_policy',
+ '_set_event_loop_policy',
+ 'set_event_loop_policy',
'get_event_loop', 'set_event_loop', 'new_event_loop',
'_set_running_loop', 'get_running_loop',
'_get_running_loop',
@@ -21,6 +23,7 @@
import subprocess
import sys
import threading
+import warnings
from . import format_helpers
@@ -765,7 +768,7 @@ def get_event_loop_policy():
return _event_loop_policy
-def set_event_loop_policy(policy):
+def _set_event_loop_policy(policy):
"""Set the current event loop policy.
If policy is None, the default policy is restored."""
@@ -774,6 +777,9 @@ def set_event_loop_policy(policy):
raise TypeError(f"policy must be an instance of
AbstractEventLoopPolicy or None, not '{type(policy).__name__}'")
_event_loop_policy = policy
+def set_event_loop_policy(policy):
+ warnings._deprecated('set_event_loop_policy', remove=(3,16))
+ _set_event_loop_policy(policy)
def get_event_loop():
"""Return an asyncio event loop.
diff --git a/Lib/test/libregrtest/save_env.py b/Lib/test/libregrtest/save_env.py
index b2cc381344b2ef..ffc29fa8dc686a 100644
--- a/Lib/test/libregrtest/save_env.py
+++ b/Lib/test/libregrtest/save_env.py
@@ -97,7 +97,7 @@ def get_asyncio_events__event_loop_policy(self):
return support.maybe_get_event_loop_policy()
def restore_asyncio_events__event_loop_policy(self, policy):
asyncio = self.get_module('asyncio')
- asyncio.set_event_loop_policy(policy)
+ asyncio._set_event_loop_policy(policy)
def get_sys_argv(self):
return id(sys.argv), sys.argv, sys.argv[:]
diff --git a/Lib/test/test_asyncgen.py b/Lib/test/test_asyncgen.py
index 4f2278bb263681..4bce6d5c1b1d2f 100644
--- a/Lib/test/test_asyncgen.py
+++ b/Lib/test/test_asyncgen.py
@@ -629,7 +629,7 @@ def setUp(self):
def tearDown(self):
self.loop.close()
self.loop = None
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def check_async_iterator_anext(self, ait_class):
with self.subTest(anext="pure-Python"):
diff --git a/Lib/test/test_asyncio/test_base_events.py
b/Lib/test/test_asyncio/test_base_events.py
index c14a0bb180d79b..08e38b047d519b 100644
--- a/Lib/test/test_asyncio/test_base_events.py
+++ b/Lib/test/test_asyncio/test_base_events.py
@@ -25,7 +25,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def mock_socket_module():
diff --git a/Lib/test/test_asyncio/test_buffered_proto.py
b/Lib/test/test_asyncio/test_buffered_proto.py
index f24e363ebfcfa3..9c386dd2e63815 100644
--- a/Lib/test/test_asyncio/test_buffered_proto.py
+++ b/Lib/test/test_asyncio/test_buffered_proto.py
@@ -5,7 +5,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class ReceiveStuffProto(asyncio.BufferedProtocol):
diff --git a/Lib/test/test_asyncio/test_context.py
b/Lib/test/test_asyncio/test_context.py
index 6b80721873d95c..ad394f44e7e5f6 100644
--- a/Lib/test/test_asyncio/test_context.py
+++ b/Lib/test/test_asyncio/test_context.py
@@ -4,7 +4,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
@unittest.skipUnless(decimal.HAVE_CONTEXTVAR, "decimal is built with a
thread-local context")
diff --git a/Lib/test/test_asyncio/test_eager_task_factory.py
b/Lib/test/test_asyncio/test_eager_task_factory.py
index 0e2b189f761521..dcf9ff716ad399 100644
--- a/Lib/test/test_asyncio/test_eager_task_factory.py
+++ b/Lib/test/test_asyncio/test_eager_task_factory.py
@@ -13,7 +13,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class EagerTaskFactoryLoopTests:
diff --git a/Lib/test/test_asyncio/test_events.py
b/Lib/test/test_asyncio/test_events.py
index 2ab638dc527aec..50df1b6ff9e09f 100644
--- a/Lib/test/test_asyncio/test_events.py
+++ b/Lib/test/test_asyncio/test_events.py
@@ -36,10 +36,10 @@
from test.support import socket_helper
from test.support import threading_helper
from test.support import ALWAYS_EQ, LARGEST, SMALLEST
-
+from test.support import warnings_helper
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def broken_unix_getsockname():
@@ -2764,13 +2764,17 @@ def test_get_event_loop_policy(self):
self.assertIs(policy, asyncio.get_event_loop_policy())
def test_set_event_loop_policy(self):
- self.assertRaises(
- TypeError, asyncio.set_event_loop_policy, object())
+ with self.assertWarnsRegex(
+ DeprecationWarning, "'set_event_loop_policy' is deprecated"):
+ self.assertRaises(
+ TypeError, asyncio.set_event_loop_policy, object())
old_policy = asyncio.get_event_loop_policy()
policy = asyncio.DefaultEventLoopPolicy()
- asyncio.set_event_loop_policy(policy)
+ with self.assertWarnsRegex(
+ DeprecationWarning, "'set_event_loop_policy' is deprecated"):
+ asyncio.set_event_loop_policy(policy)
self.assertIs(policy, asyncio.get_event_loop_policy())
self.assertIsNot(policy, old_policy)
@@ -2857,7 +2861,7 @@ def get_event_loop(self):
old_policy = asyncio.get_event_loop_policy()
try:
- asyncio.set_event_loop_policy(Policy())
+ asyncio._set_event_loop_policy(Policy())
loop = asyncio.new_event_loop()
with self.assertRaises(TestError):
@@ -2885,7 +2889,7 @@ async def func():
asyncio.get_event_loop()
finally:
- asyncio.set_event_loop_policy(old_policy)
+ asyncio._set_event_loop_policy(old_policy)
if loop is not None:
loop.close()
@@ -2897,7 +2901,7 @@ async def func():
def test_get_event_loop_returns_running_loop2(self):
old_policy = asyncio.get_event_loop_policy()
try:
- asyncio.set_event_loop_policy(asyncio.DefaultEventLoopPolicy())
+ asyncio._set_event_loop_policy(asyncio.DefaultEventLoopPolicy())
loop = asyncio.new_event_loop()
self.addCleanup(loop.close)
@@ -2923,7 +2927,7 @@ async def func():
asyncio.get_event_loop()
finally:
- asyncio.set_event_loop_policy(old_policy)
+ asyncio._set_event_loop_policy(old_policy)
if loop is not None:
loop.close()
diff --git a/Lib/test/test_asyncio/test_futures.py
b/Lib/test/test_asyncio/test_futures.py
index 3a4291e3a68ca6..7db70a4c81d483 100644
--- a/Lib/test/test_asyncio/test_futures.py
+++ b/Lib/test/test_asyncio/test_futures.py
@@ -17,7 +17,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def _fakefunc(f):
diff --git a/Lib/test/test_asyncio/test_futures2.py
b/Lib/test/test_asyncio/test_futures2.py
index b7cfffb76bd8f1..e2cddea01ecd93 100644
--- a/Lib/test/test_asyncio/test_futures2.py
+++ b/Lib/test/test_asyncio/test_futures2.py
@@ -7,7 +7,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class FutureTests:
diff --git a/Lib/test/test_asyncio/test_locks.py
b/Lib/test/test_asyncio/test_locks.py
index c3bff760f7307e..aabfcd418829b2 100644
--- a/Lib/test/test_asyncio/test_locks.py
+++ b/Lib/test/test_asyncio/test_locks.py
@@ -20,7 +20,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class LockTests(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_asyncio/test_pep492.py
b/Lib/test/test_asyncio/test_pep492.py
index 84c5f99129585b..48f4a75e0fd56c 100644
--- a/Lib/test/test_asyncio/test_pep492.py
+++ b/Lib/test/test_asyncio/test_pep492.py
@@ -11,7 +11,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
# Test that asyncio.iscoroutine() uses collections.abc.Coroutine
diff --git a/Lib/test/test_asyncio/test_proactor_events.py
b/Lib/test/test_asyncio/test_proactor_events.py
index 4b3d551dd7b3a2..24c4e8546b17aa 100644
--- a/Lib/test/test_asyncio/test_proactor_events.py
+++ b/Lib/test/test_asyncio/test_proactor_events.py
@@ -18,7 +18,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def close_transport(transport):
diff --git a/Lib/test/test_asyncio/test_protocols.py
b/Lib/test/test_asyncio/test_protocols.py
index 0f232631867db5..a8627b5b5b87f2 100644
--- a/Lib/test/test_asyncio/test_protocols.py
+++ b/Lib/test/test_asyncio/test_protocols.py
@@ -7,7 +7,7 @@
def tearDownModule():
# not needed for the test file but added for uniformness with all other
# asyncio test files for the sake of unified cleanup
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class ProtocolsAbsTests(unittest.TestCase):
diff --git a/Lib/test/test_asyncio/test_queues.py
b/Lib/test/test_asyncio/test_queues.py
index 5019e9a293525d..1a8d604faea1fd 100644
--- a/Lib/test/test_asyncio/test_queues.py
+++ b/Lib/test/test_asyncio/test_queues.py
@@ -6,7 +6,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class QueueBasicTests(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_asyncio/test_runners.py
b/Lib/test/test_asyncio/test_runners.py
index 45f70d09a2083a..f9afccc937f1de 100644
--- a/Lib/test/test_asyncio/test_runners.py
+++ b/Lib/test/test_asyncio/test_runners.py
@@ -12,7 +12,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def interrupt_self():
@@ -61,7 +61,7 @@ def setUp(self):
super().setUp()
policy = TestPolicy(self.new_loop)
- asyncio.set_event_loop_policy(policy)
+ asyncio._set_event_loop_policy(policy)
def tearDown(self):
policy = asyncio.get_event_loop_policy()
@@ -69,7 +69,7 @@ def tearDown(self):
self.assertTrue(policy.loop.is_closed())
self.assertTrue(policy.loop.shutdown_ag_run)
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
super().tearDown()
@@ -259,7 +259,7 @@ def new_event_loop():
loop.set_task_factory(Task)
return loop
- asyncio.set_event_loop_policy(TestPolicy(new_event_loop))
+ asyncio._set_event_loop_policy(TestPolicy(new_event_loop))
with self.assertRaises(asyncio.CancelledError):
asyncio.run(main())
diff --git a/Lib/test/test_asyncio/test_selector_events.py
b/Lib/test/test_asyncio/test_selector_events.py
index efca30f37414f9..f984dc96415ba3 100644
--- a/Lib/test/test_asyncio/test_selector_events.py
+++ b/Lib/test/test_asyncio/test_selector_events.py
@@ -24,7 +24,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TestBaseSelectorEventLoop(BaseSelectorEventLoop):
diff --git a/Lib/test/test_asyncio/test_sendfile.py
b/Lib/test/test_asyncio/test_sendfile.py
index 2509d4382cdebd..e1b766d06cbe1e 100644
--- a/Lib/test/test_asyncio/test_sendfile.py
+++ b/Lib/test/test_asyncio/test_sendfile.py
@@ -22,7 +22,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class MySendfileProto(asyncio.Protocol):
diff --git a/Lib/test/test_asyncio/test_server.py
b/Lib/test/test_asyncio/test_server.py
index 60a40cc8349fed..32211f4cba32cb 100644
--- a/Lib/test/test_asyncio/test_server.py
+++ b/Lib/test/test_asyncio/test_server.py
@@ -11,7 +11,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class BaseStartServer(func_tests.FunctionalTestCaseMixin):
diff --git a/Lib/test/test_asyncio/test_sock_lowlevel.py
b/Lib/test/test_asyncio/test_sock_lowlevel.py
index acef24a703ba38..5b1e5143820cad 100644
--- a/Lib/test/test_asyncio/test_sock_lowlevel.py
+++ b/Lib/test/test_asyncio/test_sock_lowlevel.py
@@ -15,7 +15,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class MyProto(asyncio.Protocol):
diff --git a/Lib/test/test_asyncio/test_ssl.py
b/Lib/test/test_asyncio/test_ssl.py
index e072ede29ee3c7..125a6c35793c44 100644
--- a/Lib/test/test_asyncio/test_ssl.py
+++ b/Lib/test/test_asyncio/test_ssl.py
@@ -29,7 +29,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class MyBaseProto(asyncio.Protocol):
diff --git a/Lib/test/test_asyncio/test_sslproto.py
b/Lib/test/test_asyncio/test_sslproto.py
index 761904c5146b6a..aa248c5786f634 100644
--- a/Lib/test/test_asyncio/test_sslproto.py
+++ b/Lib/test/test_asyncio/test_sslproto.py
@@ -21,7 +21,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
@unittest.skipIf(ssl is None, 'No ssl module')
diff --git a/Lib/test/test_asyncio/test_staggered.py
b/Lib/test/test_asyncio/test_staggered.py
index 74941f704c4890..3c81b629693596 100644
--- a/Lib/test/test_asyncio/test_staggered.py
+++ b/Lib/test/test_asyncio/test_staggered.py
@@ -8,7 +8,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class StaggeredTests(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_asyncio/test_streams.py
b/Lib/test/test_asyncio/test_streams.py
index dbe5646c2b7c08..c3ba90b309e49f 100644
--- a/Lib/test/test_asyncio/test_streams.py
+++ b/Lib/test/test_asyncio/test_streams.py
@@ -21,7 +21,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class StreamTests(test_utils.TestCase):
diff --git a/Lib/test/test_asyncio/test_subprocess.py
b/Lib/test/test_asyncio/test_subprocess.py
index ec748b9bb3e357..467e964b26c824 100644
--- a/Lib/test/test_asyncio/test_subprocess.py
+++ b/Lib/test/test_asyncio/test_subprocess.py
@@ -37,7 +37,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TestSubprocessTransport(base_subprocess.BaseSubprocessTransport):
diff --git a/Lib/test/test_asyncio/test_taskgroups.py
b/Lib/test/test_asyncio/test_taskgroups.py
index 1b4de96a572fb9..c47bf4ec9ed64b 100644
--- a/Lib/test/test_asyncio/test_taskgroups.py
+++ b/Lib/test/test_asyncio/test_taskgroups.py
@@ -14,7 +14,7 @@
# To prevent a warning "test altered the execution environment"
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class MyExc(Exception):
diff --git a/Lib/test/test_asyncio/test_tasks.py
b/Lib/test/test_asyncio/test_tasks.py
index 9d2d356631b42c..5b8979a8bbd13a 100644
--- a/Lib/test/test_asyncio/test_tasks.py
+++ b/Lib/test/test_asyncio/test_tasks.py
@@ -24,7 +24,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
async def coroutine_function():
diff --git a/Lib/test/test_asyncio/test_threads.py
b/Lib/test/test_asyncio/test_threads.py
index 774380270a7d70..c98c9a9b395ff9 100644
--- a/Lib/test/test_asyncio/test_threads.py
+++ b/Lib/test/test_asyncio/test_threads.py
@@ -8,7 +8,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class ToThreadTests(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_asyncio/test_timeouts.py
b/Lib/test/test_asyncio/test_timeouts.py
index f5543e191d07ff..3ba84d63b2ca5f 100644
--- a/Lib/test/test_asyncio/test_timeouts.py
+++ b/Lib/test/test_asyncio/test_timeouts.py
@@ -9,7 +9,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TimeoutTests(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_asyncio/test_transports.py
b/Lib/test/test_asyncio/test_transports.py
index bbdb218efaa3b6..af10d3dc2a80df 100644
--- a/Lib/test/test_asyncio/test_transports.py
+++ b/Lib/test/test_asyncio/test_transports.py
@@ -10,7 +10,7 @@
def tearDownModule():
# not needed for the test file but added for uniformness with all other
# asyncio test files for the sake of unified cleanup
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TransportTests(unittest.TestCase):
diff --git a/Lib/test/test_asyncio/test_unix_events.py
b/Lib/test/test_asyncio/test_unix_events.py
index 021f45478d6f48..e9ee9702248015 100644
--- a/Lib/test/test_asyncio/test_unix_events.py
+++ b/Lib/test/test_asyncio/test_unix_events.py
@@ -33,7 +33,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
MOCK_ANY = mock.ANY
diff --git a/Lib/test/test_asyncio/test_waitfor.py
b/Lib/test/test_asyncio/test_waitfor.py
index 11a8eeeab37634..d083f6b4d2a535 100644
--- a/Lib/test/test_asyncio/test_waitfor.py
+++ b/Lib/test/test_asyncio/test_waitfor.py
@@ -5,7 +5,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
# The following value can be used as a very small timeout:
diff --git a/Lib/test/test_asyncio/test_windows_events.py
b/Lib/test/test_asyncio/test_windows_events.py
index 0c128c599ba011..26ca5f905f752f 100644
--- a/Lib/test/test_asyncio/test_windows_events.py
+++ b/Lib/test/test_asyncio/test_windows_events.py
@@ -19,7 +19,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class UpperProto(asyncio.Protocol):
@@ -334,11 +334,11 @@ async def main():
old_policy = asyncio.get_event_loop_policy()
try:
- asyncio.set_event_loop_policy(
+ asyncio._set_event_loop_policy(
asyncio.WindowsSelectorEventLoopPolicy())
asyncio.run(main())
finally:
- asyncio.set_event_loop_policy(old_policy)
+ asyncio._set_event_loop_policy(old_policy)
def test_proactor_win_policy(self):
async def main():
@@ -348,11 +348,11 @@ async def main():
old_policy = asyncio.get_event_loop_policy()
try:
- asyncio.set_event_loop_policy(
+ asyncio._set_event_loop_policy(
asyncio.WindowsProactorEventLoopPolicy())
asyncio.run(main())
finally:
- asyncio.set_event_loop_policy(old_policy)
+ asyncio._set_event_loop_policy(old_policy)
if __name__ == '__main__':
diff --git a/Lib/test/test_asyncio/test_windows_utils.py
b/Lib/test/test_asyncio/test_windows_utils.py
index eafa5be3829682..be70720707cea7 100644
--- a/Lib/test/test_asyncio/test_windows_utils.py
+++ b/Lib/test/test_asyncio/test_windows_utils.py
@@ -16,7 +16,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class PipeTests(unittest.TestCase):
diff --git a/Lib/test/test_builtin.py b/Lib/test/test_builtin.py
index 06df217881a52f..a92edad86839e6 100644
--- a/Lib/test/test_builtin.py
+++ b/Lib/test/test_builtin.py
@@ -493,7 +493,7 @@ async def arange(n):
asyncio.run(eval(co, globals_))
self.assertEqual(globals_['a'], 1)
finally:
- asyncio.set_event_loop_policy(policy)
+ asyncio._set_event_loop_policy(policy)
def test_compile_top_level_await_invalid_cases(self):
# helper function just to check we can run top=level async-for
@@ -530,7 +530,7 @@ async def arange(n):
mode,
flags=ast.PyCF_ALLOW_TOP_LEVEL_AWAIT)
finally:
- asyncio.set_event_loop_policy(policy)
+ asyncio._set_event_loop_policy(policy)
def test_compile_async_generator(self):
diff --git a/Lib/test/test_concurrent_futures/test_interpreter_pool.py
b/Lib/test/test_concurrent_futures/test_interpreter_pool.py
index ea1512fc830d0c..93eec08bfe10d5 100644
--- a/Lib/test/test_concurrent_futures/test_interpreter_pool.py
+++ b/Lib/test/test_concurrent_futures/test_interpreter_pool.py
@@ -311,7 +311,7 @@ def setUpClass(cls):
# tests left a policy in place, just in case.
policy = support.maybe_get_event_loop_policy()
assert policy is None, policy
- cls.addClassCleanup(lambda: asyncio.set_event_loop_policy(None))
+ cls.addClassCleanup(lambda: asyncio._set_event_loop_policy(None))
def setUp(self):
super().setUp()
diff --git a/Lib/test/test_contextlib_async.py
b/Lib/test/test_contextlib_async.py
index ca7315783b9674..d8ee5757b12c15 100644
--- a/Lib/test/test_contextlib_async.py
+++ b/Lib/test/test_contextlib_async.py
@@ -11,7 +11,7 @@
support.requires_working_socket(module=True)
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TestAbstractAsyncContextManager(unittest.IsolatedAsyncioTestCase):
diff --git a/Lib/test/test_coroutines.py b/Lib/test/test_coroutines.py
index e6d65e7d90abb1..a72c43f9b47947 100644
--- a/Lib/test/test_coroutines.py
+++ b/Lib/test/test_coroutines.py
@@ -2294,7 +2294,7 @@ async def f():
pass
finally:
loop.close()
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
self.assertEqual(buffer, [1, 2, 'MyException'])
diff --git a/Lib/test/test_inspect/test_inspect.py
b/Lib/test/test_inspect/test_inspect.py
index 1ecf18bf49fa7e..2c950e46b3ed8a 100644
--- a/Lib/test/test_inspect/test_inspect.py
+++ b/Lib/test/test_inspect/test_inspect.py
@@ -75,7 +75,7 @@ def revise(filename, *args):
def tearDownModule():
if support.has_socket_support:
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
def signatures_with_lexicographic_keyword_only_parameters():
diff --git a/Lib/test/test_logging.py b/Lib/test/test_logging.py
index 671b4c57a809aa..44c854f02a73c6 100644
--- a/Lib/test/test_logging.py
+++ b/Lib/test/test_logging.py
@@ -5352,7 +5352,7 @@ def test_taskName_with_asyncio_imported(self):
logging.logAsyncioTasks = False
runner.run(make_record(self.assertIsNone))
finally:
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
@support.requires_working_socket()
def test_taskName_without_asyncio_imported(self):
@@ -5364,7 +5364,7 @@ def test_taskName_without_asyncio_imported(self):
logging.logAsyncioTasks = False
runner.run(make_record(self.assertIsNone))
finally:
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class BasicConfigTest(unittest.TestCase):
@@ -5668,7 +5668,7 @@ async def log_record():
data = f.read().strip()
self.assertRegex(data, r'Task-\d+ - hello world')
finally:
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
if handler:
handler.close()
diff --git a/Lib/test/test_os.py b/Lib/test/test_os.py
index b0e686cb754b93..d688a225538c11 100644
--- a/Lib/test/test_os.py
+++ b/Lib/test/test_os.py
@@ -105,7 +105,7 @@ def create_file(filename, content=b'content'):
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class MiscTests(unittest.TestCase):
diff --git a/Lib/test/test_pdb.py b/Lib/test/test_pdb.py
index 48a4c568651879..58295cff84310f 100644
--- a/Lib/test/test_pdb.py
+++ b/Lib/test/test_pdb.py
@@ -2132,7 +2132,7 @@ def test_pdb_next_command_for_asyncgen():
... loop = asyncio.new_event_loop()
... loop.run_until_complete(test_main())
... loop.close()
- ... asyncio.set_event_loop_policy(None)
+ ... asyncio._set_event_loop_policy(None)
... print("finished")
>>> with PdbTestInput(['step',
@@ -2253,7 +2253,7 @@ def test_pdb_return_command_for_coroutine():
... loop = asyncio.new_event_loop()
... loop.run_until_complete(test_main())
... loop.close()
- ... asyncio.set_event_loop_policy(None)
+ ... asyncio._set_event_loop_policy(None)
... print("finished")
>>> with PdbTestInput(['step',
@@ -2353,7 +2353,7 @@ def test_pdb_until_command_for_coroutine():
... loop = asyncio.new_event_loop()
... loop.run_until_complete(test_main())
... loop.close()
- ... asyncio.set_event_loop_policy(None)
+ ... asyncio._set_event_loop_policy(None)
... print("finished")
>>> with PdbTestInput(['step',
diff --git a/Lib/test/test_sys_settrace.py b/Lib/test/test_sys_settrace.py
index 95cf0d1ec2d9ab..e5cf88177f7131 100644
--- a/Lib/test/test_sys_settrace.py
+++ b/Lib/test/test_sys_settrace.py
@@ -2070,7 +2070,7 @@ def run_async_test(self, func, jumpFrom, jumpTo,
expected, error=None,
asyncio.run(func(output))
sys.settrace(None)
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
self.compare_jump_output(expected, output)
def jump_test(jumpFrom, jumpTo, expected, error=None, event='line',
warning=None):
diff --git a/Lib/test/test_unittest/test_async_case.py
b/Lib/test/test_unittest/test_async_case.py
index 8ea244bff05c5f..664ca5efe57f84 100644
--- a/Lib/test/test_unittest/test_async_case.py
+++ b/Lib/test/test_unittest/test_async_case.py
@@ -12,7 +12,7 @@ class MyException(Exception):
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TestCM:
@@ -490,7 +490,7 @@ async def test_demo1(self):
self.assertTrue(result.wasSuccessful())
def test_loop_factory(self):
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class TestCase1(unittest.IsolatedAsyncioTestCase):
loop_factory = asyncio.EventLoop
diff --git a/Lib/test/test_unittest/testmock/testasync.py
b/Lib/test/test_unittest/testmock/testasync.py
index 73f04291373f91..afc9d1f11da1e2 100644
--- a/Lib/test/test_unittest/testmock/testasync.py
+++ b/Lib/test/test_unittest/testmock/testasync.py
@@ -15,7 +15,7 @@
def tearDownModule():
- asyncio.set_event_loop_policy(None)
+ asyncio._set_event_loop_policy(None)
class AsyncClass:
_______________________________________________
Python-checkins mailing list -- [email protected]
To unsubscribe send an email to [email protected]
https://mail.python.org/mailman3/lists/python-checkins.python.org/
Member address: [email protected]
