summaryrefslogtreecommitdiffstats
path: root/Lib/test/test_contextlib_async.py
diff options
context:
space:
mode:
authorJohn Belmonte <john@neggie.net>2021-10-04 06:49:55 (GMT)
committerGitHub <noreply@github.com>2021-10-04 06:49:55 (GMT)
commite6d1aa1ac65b6908fdea2c70ec3aa8c4f1dffcb5 (patch)
tree317af9f26a2c7233a73b2fadccd23f91b5f254c5 /Lib/test/test_contextlib_async.py
parenta25dcaefb7c4eb0767a112cd31fe0b055f168844 (diff)
downloadcpython-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.py35
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()