Skip to content

Commit 9fc105f

Browse files
authored
Apply suggestions from code review
1 parent dd55eae commit 9fc105f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

Lib/asyncio/staggered.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ def task_done(task):
7676
and not on_completed_fut.done()
7777
and not running_tasks
7878
):
79-
on_completed_fut.set_result(True)
79+
on_completed_fut.set_result(None)
8080

8181
if task.cancelled():
8282
return
@@ -110,7 +110,7 @@ async def run_one_coro(ok_to_start, previous_failed) -> None:
110110
next_task = loop.create_task(run_one_coro(next_ok_to_start, this_failed))
111111
running_tasks.add(next_task)
112112
next_task.add_done_callback(task_done)
113-
# next_task has been appended to running_tasks so next_task is ok to
113+
# next_task has been appended to running_tasks so next_task is ok to
114114
# start.
115115
next_ok_to_start.set()
116116
# Prepare place to put this coroutine's exceptions if not won
@@ -166,7 +166,7 @@ async def run_one_coro(ok_to_start, previous_failed) -> None:
166166
if __debug__ and unhandled_exceptions:
167167
# If run_one_coro raises an unhandled exception, it's probably a
168168
# programming error, and I want to see it.
169-
raise ExceptionGroup("multiple errors in staggered race", unhandled_exceptions)
169+
raise ExceptionGroup("staggered race failed", unhandled_exceptions)
170170
if propagate_cancellation_error is not None:
171171
raise propagate_cancellation_error
172172
return winner_result, winner_index, exceptions

0 commit comments

Comments
 (0)