diff options
author | Serhiy Storchaka <storchaka@gmail.com> | 2023-01-13 12:40:29 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-01-13 12:40:29 (GMT) |
commit | e5bd5ad70d9e549eeb80aadb4f3ccb0f2f23266d (patch) | |
tree | 3c13553b04873b8cd80d10a877740031aa324b31 /Lib/asyncio | |
parent | 468c3bf79890ef614764b4e7543608876c792794 (diff) | |
download | cpython-e5bd5ad70d9e549eeb80aadb4f3ccb0f2f23266d.zip cpython-e5bd5ad70d9e549eeb80aadb4f3ccb0f2f23266d.tar.gz cpython-e5bd5ad70d9e549eeb80aadb4f3ccb0f2f23266d.tar.bz2 |
gh-100160: Restore and deprecate implicit creation of an event loop (GH-100410)
Partially revert changes made in GH-93453.
asyncio.DefaultEventLoopPolicy.get_event_loop() now emits a
DeprecationWarning and creates and sets a new event loop instead of
raising a RuntimeError if there is no current event loop set.
Co-authored-by: Guido van Rossum <gvanrossum@gmail.com>
Diffstat (limited to 'Lib/asyncio')
-rw-r--r-- | Lib/asyncio/events.py | 24 |
1 files changed, 23 insertions, 1 deletions
diff --git a/Lib/asyncio/events.py b/Lib/asyncio/events.py index 6cff8c5..ce44942 100644 --- a/Lib/asyncio/events.py +++ b/Lib/asyncio/events.py @@ -619,7 +619,7 @@ class AbstractEventLoopPolicy: Returns an event loop object implementing the BaseEventLoop interface, or raises an exception in case no event loop has been set for the - current context. + current context and the current policy does not specify to create one. It should never return None.""" raise NotImplementedError @@ -672,6 +672,28 @@ class BaseDefaultEventLoopPolicy(AbstractEventLoopPolicy): Returns an instance of EventLoop or raises an exception. """ + if (self._local._loop is None and + not self._local._set_called and + threading.current_thread() is threading.main_thread()): + stacklevel = 2 + try: + f = sys._getframe(1) + except AttributeError: + pass + else: + # Move up the call stack so that the warning is attached + # to the line outside asyncio itself. + while f: + module = f.f_globals.get('__name__') + if not (module == 'asyncio' or module.startswith('asyncio.')): + break + f = f.f_back + stacklevel += 1 + import warnings + warnings.warn('There is no current event loop', + DeprecationWarning, stacklevel=stacklevel) + self.set_event_loop(self.new_event_loop()) + if self._local._loop is None: raise RuntimeError('There is no current event loop in thread %r.' % threading.current_thread().name) |