diff --git a/Lib/asyncio/staggered.py b/Lib/asyncio/staggered.py index c3a7441a7b091d..43b55376b5b6f5 100644 --- a/Lib/asyncio/staggered.py +++ b/Lib/asyncio/staggered.py @@ -116,7 +116,7 @@ async def run_one_coro(previous_failed) -> None: if i != this_index: t.cancel() - first_task = loop.create_task(run_one_coro(None)) + first_task = loop.create_task(run_one_coro(locks.Event())) running_tasks.append(first_task) try: # Wait for a growing list of tasks to all finish: poor man's version of