8000 bpo-42130: Fix for explicit suppressing of cancellations in wait_for() by Dreamsorcerer · Pull Request #28149 · python/cpython · GitHub
[go: up one dir, main page]
Skip to content

bpo-42130: Fix for explicit suppressing of cancellations in wait_for() #28149

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 20 commits into from
Closed

bpo-42130: Fix for explicit suppressing of cancellations in wait_for() #28149

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
9c2942a
Create test for suppressing cancellations
Dreamsorcerer Sep 3, 2021
7ff2c04
Update test_tasks.py
Dreamsorcerer Sep 3, 2021
cdaa9c8
Update test_tasks.py
Dreamsorcerer Sep 3, 2021
342222f
Update test_tasks.py
Dreamsorcerer Sep 3, 2021
01d9884
Use a sentinel
Dreamsorcerer Sep 3, 2021
af96f10
Fix test for issue37658
Dreamsorcerer Sep 4, 2021
1e5233d
Update test_tasks.py
Dreamsorcerer Sep 4, 2021
743177e
Fix original issue
Dreamsorcerer Sep 4, 2021
d7c0965
Remove test
Dreamsorcerer Sep 4, 2021
80f027b
Merge branch 'main' into patch-4
Dreamsorcerer Nov 29, 2021
4eb5de2
Create 2021-11-29-17-17-45.bpo-42130.Ho8dUh.rst
Dreamsorcerer Nov 29, 2021
a8f5c1f
Compare to tuple
Dreamsorcerer Dec 1, 2021
5de6b79
Use enum for sentinel
Dreamsorcerer Dec 1, 2021
5a79cf2
Missing import
Dreamsorcerer Dec 1, 2021
11e1214
Update tasks.py
Dreamsorcerer Dec 6, 2021
3a35126
Update tasks.py
Dreamsorcerer Dec 6, 2021
df15ac1
Update test_tasks.py
Dreamsorcerer Dec 15, 2021
7374366
Update tasks.py
Dreamsorcerer Dec 15, 2021
c694173
Revert mistaken changes.
Dreamsorcerer Dec 15, 2021
cb59377
Update 2021-11-29-17-17-45.bpo-42130.Ho8dUh.rst
Dreamsorcerer Dec 15, 2021
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
Revert mistaken changes.
  • Loading branch information
@Dreamsorcerer
Dreamsorcerer authored Dec 15, 2021
commit c6941733a7200d0a3bc4f18b8bf4567f18a0795a
14 changes: 3 additions & 11 deletions Lib/asyncio/tasks.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -389,7 +389,7 @@ def _release_waiter(waiter, *args):
waiter.set_result(None)


async def wait_for(fut, timeout, *, loop=None):
async def wait_for(fut, timeout):
"""Wait for the single Future or coroutine to complete, with timeout.

Coroutine will be wrapped in Task.
Expand All @@ -402,12 +402,7 @@ async def wait_for(fut, timeout, *, loop=None):

This function is a coroutine.
"""
if loop is None:
loop = events.get_running_loop()
else:
warnings.warn("The loop argument is deprecated since Python 3.8, "
"and scheduled for removal in Python 3.10.",
DeprecationWarning, stacklevel=2)
loop = events.get_running_loop()

if timeout is None:
return await fut
Expand All @@ -426,10 +421,7 @@ async def wait_for(fut, timeout, *, loop=None):

waiter = loop.create_future()
timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
#cb = functools.partial(_release_waiter, waiter)

def cb(f):
_release_waiter(waiter)
cb = functools.partial(_release_waiter, waiter)

fut = ensure_future(fut, loop=loop)
fut.add_done_callback(cb)
Expand Down
0