mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-04 00:48:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Issue #22601: run_forever() now consumes BaseException of the temporary task

Browse source 
If the coroutine raised a BaseException, consume the exception to not log a
warning. The caller doesn't have access to the local task.
This commit is contained in:
Victor Stinner 2014-10-11 14:30:18 +02:00
parent 682124ccc3
commit c8bd53f815
2 changed files with 30 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
Lib/asyncio/base_events.py
View file

@ -268,7 +268,15 @@ class BaseEventLoop(events.AbstractEventLoop):
future._log_destroy_pending = False
future.add_done_callback(_raise_stop_error)
self.run_forever()
try:
self.run_forever()
except:
if new_task and future.done() and not future.cancelled():
# The coroutine raised a BaseException. Consume the exception
# to not log a warning, the caller doesn't have access to the
# local task.
future.exception()
raise
future.remove_done_callback(_raise_stop_error)
if not future.done():
raise RuntimeError('Event loop stopped before Future completed.')