traceback.clear_frames manages to deadlock a background task

[tvoinarovskyi]

BPO	35751
Nosy	@asvetlov, @1st1, @tvoinarovskyi
Files	test_async_deadlock.py: Script to reproduce issue

^{Note: these values reflect the state of the issue at the time it was migrated and might not reflect the current state.}

Show more details

GitHub fields:

assignee = None
closed_at = None
created_at = <Date 2019-01-16.10:34:07.787>
labels = ['type-bug', '3.7', 'expert-asyncio']
title = 'traceback.clear_frames manages to deadlock a background task'
updated_at = <Date 2019-01-17.00:50:59.457>
user = 'https://github.com/tvoinarovskyi'

bugs.python.org fields:

activity = <Date 2019-01-17.00:50:59.457>
actor = 'tvoinarovskyi'
assignee = 'none'
closed = False
closed_date = None
closer = None
components = ['asyncio']
creation = <Date 2019-01-16.10:34:07.787>
creator = 'tvoinarovskyi'
dependencies = []
files = ['48059']
hgrepos = []
issue_num = 35751
keywords = []
message_count = 4.0
messages = ['333759', '333770', '333775', '333808']
nosy_count = 3.0
nosy_names = ['asvetlov', 'yselivanov', 'tvoinarovskyi']
pr_nums = []
priority = 'normal'
resolution = None
stage = None
status = 'open'
superseder = None
type = 'behavior'
url = 'https://bugs.python.org/issue35751'
versions = ['Python 3.6', 'Python 3.7']

Linked PRs

• gh-79932: raise exception if frame.clear() is called on a suspended frame #111792

[tvoinarovskyi]

My use case:
I have a background task, say called "coordination". In that task, I want to catch any errors and push those to the user waiting in the main task and only continue running the background coroutine after the user manually resolves the exception.

Issue:
When testing the behaviour with unittest.Case and using assertRaises to catch the exception, the background coroutine manages to just freeze. I have narrowed it down to traceback.clear_frames in assertRaises that causes a GeneratorExit in the background coroutine.

I believe this issue is a duplicate to https://bugs.python.org/issue29211, but wanted to provide another actual use case where it can pop up. Also even if the generator raises a GeneratorExit, why did the background thread freeze is still a mystery to me.

Script to reproduce in my case is attached.

[tvoinarovskyi]

So yes, the clear_frames function will force a running generator to close. See https://github.com/python/cpython/blob/3.7/Objects/frameobject.c#L566, it explicitly does a Finalize. Would that be the desired behaviour for assertRaises is not clear. I find it strange that catching an exception is closing my running coroutine.

The reproduce example can be lowered to something like::

 import asyncio


 async def background(error_future):
 try:
 raise ValueError
 except Exception as exc:
 error_future.set_exception(exc)


 await asyncio.sleep(1)

 async def main():
 loop = asyncio.get_event_loop()
 error_future = loop.create_future()
 task = asyncio.create_task(background(error_future))

 await asyncio.wait([error_future])
 exc = error_future.exception()
 import traceback
 traceback.clear_frames(exc.__traceback__)

 # Will block forever, as task will never be waken up
 await task


 if __name__ == "__main__":
 asyncio.run(main())

[1st1]

Very interesting. Thanks for reporting this issue. I'll definitely take a look at this before 3.8 is released. For 3.7 you'll likely have to find a workaround.

[tvoinarovskyi]

For now, it seems like copy.copy(exception) before raising seems to prevent this behaviour. So for all exceptions originating from background tasks I raise a copy to the user, rather than the original exception. It prints correct stack, so no real impact on the library.

[kumaraditya303]

traceback.clear_frames can close generators too so this is not special to coroutines and asyncio. I guess the simple solution here is "don't do that".

[gvanrossum]

@iritkatriel ^^

[iritkatriel]

I think this is the fix:

diff --git a/Objects/frameobject.c b/Objects/frameobject.c
index dd69207571..a512acf3f0 100644
--- a/Objects/frameobject.c
+++ b/Objects/frameobject.c
@@ -949,7 +949,8 @@ frame_clear(PyFrameObject *f, PyObject *Py_UNUSED(ignored))
{
 if (f->f_frame->owner == FRAME_OWNED_BY_GENERATOR){
 PyGenObject *gen = _PyFrame_GetGenerator(f->f_frame);
- if (gen->gi_frame_state == FRAME_EXECUTING){
+ if (gen->gi_frame_state == FRAME_EXECUTING ||
+ gen->gi_frame_state == FRAME_SUSPENDED){
 goto running;
 }
 _PyGen_Finalize((PyObject *)gen);

But when I apply it we get two failures from tests that seem to imply that the current behaviour is a feature:

======================================================================
ERROR: test_clear_executing_generator (test.test_frame.ClearTest.test_clear_executing_generator)
----------------------------------------------------------------------
Traceback (most recent call last):
 File "/Users/iritkatriel/src/cpython/Lib/test/test_frame.py", line 112, in test_clear_executing_generator
 f.clear()
RuntimeError: cannot clear an executing frame

======================================================================
ERROR: test_clear_generator (test.test_frame.ClearTest.test_clear_generator)
----------------------------------------------------------------------
Traceback (most recent call last):
 File "/Users/iritkatriel/src/cpython/Lib/test/test_frame.py", line 78, in test_clear_generator
 gen.gi_frame.clear()
RuntimeError: cannot clear an executing frame

----------------------------------------------------------------------