mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-07-24 03:35:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

gh-119121: Fix and test async.staggered.staggered_race (#119173)

Browse source
This commit is contained in:
Nikita Sobolev 2024-05-20 14:06:50 +03:00 • committed by GitHub
parent 357f5a1f73
commit 16b46ebd2b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 100 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
Lib/asyncio/staggered.py
View file

@ -69,8 +69,7 @@ async def staggered_race(coro_fns, delay, *, loop=None):
exceptions = []
running_tasks = []
async def run_one_coro(
previous_failed: typing.Optional[locks.Event]) -> None:
async def run_one_coro(previous_failed) -> None:
# Wait for the previous task to finish, or for delay seconds
if previous_failed is not None:
with contextlib.suppress(exceptions_mod.TimeoutError):