https://github.com/python/cpython/commit/49bd47d5f14993d37b97aa2bbf257f5df16b96a9
commit: 49bd47d5f14993d37b97aa2bbf257f5df16b96a9
branch: main
author: Kumar Aditya <kumaradi...@python.org>
committer: kumaraditya303 <kumaradi...@python.org>
date: 2025-02-07T18:00:59Z
summary:
improve `test_log_destroyed_pending_task` in asyncio (#129821)
files:
M Lib/test/test_asyncio/test_tasks.py
diff --git a/Lib/test/test_asyncio/test_tasks.py
b/Lib/test/test_asyncio/test_tasks.py
index cd4a48499e8f11..881a7aeeb2fbe5 100644
--- a/Lib/test/test_asyncio/test_tasks.py
+++ b/Lib/test/test_asyncio/test_tasks.py
@@ -2254,7 +2254,6 @@ def test_wait_invalid_args(self):
asyncio.wait([]))
def test_log_destroyed_pending_task(self):
- Task = self.__class__.Task
async def kill_me(loop):
future = self.new_future(loop)
@@ -2269,7 +2268,7 @@ async def kill_me(loop):
# schedule the task
coro = kill_me(self.loop)
- task = asyncio.ensure_future(coro, loop=self.loop)
+ task = self.new_task(self.loop, coro)
self.assertEqual(self.all_tasks(loop=self.loop), {task})
@@ -2286,14 +2285,17 @@ async def kill_me(loop):
# no more reference to kill_me() task: the task is destroyed by the GC
support.gc_collect()
- self.assertEqual(self.all_tasks(loop=self.loop), set())
-
mock_handler.assert_called_with(self.loop, {
'message': 'Task was destroyed but it is pending!',
'task': mock.ANY,
'source_traceback': source_traceback,
})
mock_handler.reset_mock()
+ # task got resurrected by the exception handler
+ support.gc_collect()
+
+ self.assertEqual(self.all_tasks(loop=self.loop), set())
+
@mock.patch('asyncio.base_events.logger')
def test_tb_logger_not_called_after_cancel(self, m_log):
_______________________________________________
Python-checkins mailing list -- python-checkins@python.org
To unsubscribe send an email to python-checkins-le...@python.org
https://mail.python.org/mailman3/lists/python-checkins.python.org/
Member address: arch...@mail-archive.com
