PyCharm debug报错no running event loop

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

Traceback (most recent call last):
  File "xxxx\.venv\Lib\site-packages\streamlit\web\bootstrap.py", line 348, in run
    if asyncio.get_running_loop().is_running():
       ^^^^^^^^^^^^^^^^^^^^^^^^^^
RuntimeError: no running event loop

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "xxx\Python311\Lib\asyncio\events.py", line 84, in _run
    self._context.run(self._callback, *self._args)
TypeError: 'Task' object is not callable

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

try:  
# Check if we're already in an event loop  
	if asyncio.get_running_loop().is_running():  
		# Use `asyncio.create_task` if we're in an async context  
		# TODO(lukasmasuch): Do we have to store a reference for the task here?        asyncio.create_task(main())  # noqa: RUF006  
	else:  
		# Otherwise, use `asyncio.run`  
		asyncio.run(main())  
except RuntimeError:  
	# get_running_loop throws RuntimeError if no running event loop  
	asyncio.run(main())

1
2
3
4
5
6
7
8
9

graph TD
  A[用户启动调试] --> B[PyCharm 创建调试进程]
  B --> C[加载 pydevd 调试器]
  C --> D[检测异步环境]
  D --> E{是否异步代码？}
  E -- 是 --> F[创建控制事件循环]
  E -- 否 --> G[正常执行]
  F --> H[注入调试钩子]
  H --> I[运行用户代码]

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

if IS_ASYNCIO_DEBUGGER_ENV:
...
	def _apply(loop=None):  
	    """ Patch asyncio to make its event loop reentrant. """
	    ...

	def _patch_asyncio():  
	    """  
	    Patch asyncio module to use pure Python tasks and futures,
	    use module level _current_tasks, all_tasks and patch run method.    
	    """
	    ...

	def _patch_policy():  
	    """Patch the policy to always return a patched loop."""
	    ...

	def _patch_loop(loop):  
	    """Patch loop to make it reentrant."""
	    ...

	def _patch_task():  
	    """Patch the Task's step and enter/leave methods to make it reentrant."""
	    ...

...

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

def _patch_loop(loop):  
    """Patch loop to make it reentrant."""

	def run_forever(self):
		...
	def run_until_complete(self, future):
		...
	def call_soon(self, callback, *args, context=None):
		...
	...
	if hasattr(loop, '_pydevd_nest_patched'):  
	    return  
	if not isinstance(loop, asyncio.BaseEventLoop):  
	    raise ValueError('Can\'t patch loop of type %s' % type(loop))  
	cls = loop.__class__  
	cls.run_forever = run_forever  
	cls.run_until_complete = run_until_complete  
	cls._run_once = _run_once  
	cls.call_soon = call_soon
	...

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

if env_util.IS_WINDOWS:
	try:
		from asyncio import (  # type: ignore[attr-defined]
			WindowsProactorEventLoopPolicy,
			WindowsSelectorEventLoopPolicy,
		)
	except ImportError:
		pass
		# Not affected
	else:
		if type(asyncio.get_event_loop_policy()) is WindowsProactorEventLoopPolicy:
			# WindowsProactorEventLoopPolicy is not compatible with
			# Tornado 6 fallback to the pre-3.8 default of Selector
			asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy())

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

def run(main, debug=False):  
    loop = _PydevdAsyncioUtils.get_event_loop()  
    loop.set_debug(debug)  
    task = asyncio.ensure_future(main)  
    try:  
        return loop.run_until_complete(task)  
    finally:  
        if not task.done():  
            task.cancel()  
            with suppress(asyncio.CancelledError):  
                loop.run_until_complete(task)