Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
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
5 changes: 5 additions & 0 deletions Lib/asyncio/taskgroups.py
Original file line number Diff line number Diff line change
Expand Up @@ -205,6 +205,11 @@ def create_task(self, coro, *, name=None, context=None):
else:
self._tasks.add(task)
task.add_done_callback(self._on_task_done)
if self._aborting:
Comment thread
graingert marked this conversation as resolved.
# gh-128550: if this task is eager it might have started
# another eager task that aborts us, if so we must cancel
# this task.
task.cancel()
try:
return task
finally:
Expand Down
26 changes: 26 additions & 0 deletions Lib/test/test_asyncio/test_taskgroups.py
Original file line number Diff line number Diff line change
Expand Up @@ -1040,6 +1040,32 @@ class MyKeyboardInterrupt(KeyboardInterrupt):
self.assertIsNotNone(exc)
self.assertListEqual(gc.get_referrers(exc), no_other_refs())

async def test_cancels_task_if_created_during_creation(self):
Comment thread
graingert marked this conversation as resolved.
Comment thread
graingert marked this conversation as resolved.
# regression test for gh-128550
ran = False
class MyError(Exception):
pass

exc = None
try:
Comment thread
graingert marked this conversation as resolved.
async with asyncio.TaskGroup() as tg:
async def third_task():
raise MyError("third task failed")

async def second_task():
nonlocal ran
tg.create_task(third_task())
with self.assertRaises(asyncio.CancelledError):
await asyncio.sleep(0) # eager tasks cancel here
await asyncio.sleep(0) # lazy tasks cancel here
ran = True

tg.create_task(second_task())
except* MyError as excs:
exc = excs.exceptions[0]
Comment thread
graingert marked this conversation as resolved.

self.assertTrue(ran)
Comment thread
graingert marked this conversation as resolved.
Comment thread
graingert marked this conversation as resolved.
self.assertIsInstance(exc, MyError)

class TestTaskGroup(BaseTestTaskGroup, unittest.IsolatedAsyncioTestCase):
loop_factory = asyncio.EventLoop
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Fix a deadlock in :class:`asyncio.TaskGroup` when using eager tasks that abort the task group too early.