8000 GH-86296: Fix for asyncio.wait_for() swallowing cancellation, and add tests by twisteroidambassador · Pull Request #98607 · python/cpython · GitHub
[go: up one dir, main page]
Skip to content

GH-86296: Fix for asyncio.wait_for() swallowing cancellation, and add tests #98607

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 7 commits into from
Closed

GH-86296: Fix for asyncio.wait_for() swallowing cancellation, and add tests #98607

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
c1649a9
Add tests for wait_for() behavior when things happen simultaneously.
twisteroidambassador Oct 24, 2022
992d843
Actually use do_cancel argument.
twisteroidambassador Oct 24, 2022
55f5547
Ensure wait_for() does not swallow cancellation.
twisteroidambassador Oct 25, 2022
c834122
Remove tests for simultaneous *timeout* and *inner becoming done*.
twisteroidambassador Oct 26, 2022
7660179
Spec change: when cancelled, always raise CancelledError.
twisteroidambassador Oct 26, 2022
02a624c
📜🤖 Added by blurb_it.
blurb-it[bot] Oct 26, 2022
baf5d1b
Merge branch 'main' into wait_for_specs
kumaraditya303 Dec 14, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Ensure wait_for() does not swallow cancellation.
  • Loading branch information
@twisteroidambassador
twisteroidambassador committed Oct 25, 2022
commit 55f5547c704651423739449afb6ff8527d33b5d4
11 changes: 6 additions & 5 deletions Lib/asyncio/tasks.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -468,15 +468,16 @@ async def wait_for(fut, timeout):
try:
await waiter
except exceptions.CancelledError:
if fut.done():
return fut.result()
else:
fut.remove_done_callback(cb)
if not fut.done():
# We must ensure that the task is not running
# after wait_for() returns.
# See https://bugs.python.org/issue32751
fut.remove_done_callback(cb)
await _cancel_and_wait(fut, loop=loop)
raise
exc = fut.exception()
if exc: # If fut.cancelled(), this will raise CancelledError
raise exc
raise

if fut.done():
return fut.result()
Expand Down
0