From 929afd1d6ee4fb89ac818037effe6577947103de Mon Sep 17 00:00:00 2001 From: sobolevn Date: Mon, 24 Mar 2025 22:00:48 +0300 Subject: gh-131670: Fix crash in `anext()` when `__anext__` is sync and raises (#131682) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Bénédikt Tran <10796600+picnixz@users.noreply.github.com> --- Lib/test/test_asyncgen.py | 20 ++++++++++++++++++++ .../2025-03-24-19-38-53.gh-issue-131670.IffOZj.rst | 1 + Python/bltinmodule.c | 3 +++ 3 files changed, 24 insertions(+) create mode 100644 Misc/NEWS.d/next/Core_and_Builtins/2025-03-24-19-38-53.gh-issue-131670.IffOZj.rst diff --git a/Lib/test/test_asyncgen.py b/Lib/test/test_asyncgen.py index b811878..d7dcf61 100644 --- a/Lib/test/test_asyncgen.py +++ b/Lib/test/test_asyncgen.py @@ -1169,6 +1169,26 @@ class AsyncGenAsyncioTest(unittest.TestCase): self.loop.run_until_complete(run()) + def test_sync_anext_raises_exception(self): + # See: https://github.com/python/cpython/issues/131670 + msg = 'custom' + for exc_type in [ + StopAsyncIteration, + StopIteration, + ValueError, + Exception, + ]: + exc = exc_type(msg) + with self.subTest(exc=exc): + class A: + def __anext__(self): + raise exc + + with self.assertRaisesRegex(exc_type, msg): + anext(A()) + with self.assertRaisesRegex(exc_type, msg): + anext(A(), 1) + def test_async_gen_asyncio_anext_stopiteration(self): async def foo(): try: diff --git a/Misc/NEWS.d/next/Core_and_Builtins/2025-03-24-19-38-53.gh-issue-131670.IffOZj.rst b/Misc/NEWS.d/next/Core_and_Builtins/2025-03-24-19-38-53.gh-issue-131670.IffOZj.rst new file mode 100644 index 0000000..812a75a --- /dev/null +++ b/Misc/NEWS.d/next/Core_and_Builtins/2025-03-24-19-38-53.gh-issue-131670.IffOZj.rst @@ -0,0 +1 @@ +Fix :func:`anext` failing on sync :meth:`~object.__anext__` raising an exception. diff --git a/Python/bltinmodule.c b/Python/bltinmodule.c index 6709f30..f776120 100644 --- a/Python/bltinmodule.c +++ b/Python/bltinmodule.c @@ -1837,6 +1837,9 @@ builtin_anext_impl(PyObject *module, PyObject *aiterator, } awaitable = (*t->tp_as_async->am_anext)(aiterator); + if (awaitable == NULL) { + return NULL; + } if (default_value == NULL) { return awaitable; } -- cgit v0.12