diff options
author | John Belmonte <john@neggie.net> | 2021-10-04 06:49:55 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-10-04 06:49:55 (GMT) |
commit | e6d1aa1ac65b6908fdea2c70ec3aa8c4f1dffcb5 (patch) | |
tree | 317af9f26a2c7233a73b2fadccd23f91b5f254c5 /Lib/test/test_contextlib_async.py | |
parent | a25dcaefb7c4eb0767a112cd31fe0b055f168844 (diff) | |
download | cpython-e6d1aa1ac65b6908fdea2c70ec3aa8c4f1dffcb5.zip cpython-e6d1aa1ac65b6908fdea2c70ec3aa8c4f1dffcb5.tar.gz cpython-e6d1aa1ac65b6908fdea2c70ec3aa8c4f1dffcb5.tar.bz2 |
bpo-44594: fix (Async)ExitStack handling of __context__ (gh-27089)
* bpo-44594: fix (Async)ExitStack handling of __context__
Make enter_context(foo()) / enter_async_context(foo()) equivalent to
`[async] with foo()` regarding __context__ when an exception is raised.
Previously exceptions would be caught and re-raised with the wrong
context when explicitly overriding __context__ with None.
Diffstat (limited to 'Lib/test/test_contextlib_async.py')
-rw-r--r-- | Lib/test/test_contextlib_async.py | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/Lib/test/test_contextlib_async.py b/Lib/test/test_contextlib_async.py index c738bf3..c16c7ec 100644 --- a/Lib/test/test_contextlib_async.py +++ b/Lib/test/test_contextlib_async.py @@ -647,6 +647,41 @@ class TestAsyncExitStack(TestBaseExitStack, unittest.TestCase): self.assertIsInstance(inner_exc.__context__, ZeroDivisionError) @_async_test + async def test_async_exit_exception_explicit_none_context(self): + # Ensure AsyncExitStack chaining matches actual nested `with` statements + # regarding explicit __context__ = None. + + class MyException(Exception): + pass + + @asynccontextmanager + async def my_cm(): + try: + yield + except BaseException: + exc = MyException() + try: + raise exc + finally: + exc.__context__ = None + + @asynccontextmanager + async def my_cm_with_exit_stack(): + async with self.exit_stack() as stack: + await stack.enter_async_context(my_cm()) + yield stack + + for cm in (my_cm, my_cm_with_exit_stack): + with self.subTest(): + try: + async with cm(): + raise IndexError() + except MyException as exc: + self.assertIsNone(exc.__context__) + else: + self.fail("Expected IndexError, but no exception was raised") + + @_async_test async def test_instance_bypass_async(self): class Example(object): pass cm = Example() |