diff --git a/app/core/observe.py b/app/core/observe.py index 1f4cb75..59b4bd1 100644 --- a/app/core/observe.py +++ b/app/core/observe.py @@ -11,12 +11,12 @@ from app.core.config import settings # 有界事件队列(懒创建,见 get_queue):首次取用时在运行中的 loop 里建,避免 import 期 # 无 loop 的边角问题;put_nowait/get_nowait 不需运行中的 loop → 可在无 loop 下测试。 -_queue: "asyncio.Queue[dict] | None" = None +_queue: asyncio.Queue[dict] | None = None # 队列满时的丢弃计数,worker 定期取出打日志。 _dropped = 0 -def get_queue() -> "asyncio.Queue[dict]": +def get_queue() -> asyncio.Queue[dict]: """返回全局有界事件队列(懒创建)。测试可 monkeypatch 模块级 _queue 换成小队列。""" global _queue if _queue is None: diff --git a/tests/test_observe.py b/tests/test_observe.py index 0d49dc3..aada50c 100644 --- a/tests/test_observe.py +++ b/tests/test_observe.py @@ -7,8 +7,8 @@ from __future__ import annotations import asyncio -from app.core.config import settings from app.core import observe +from app.core.config import settings def test_observe_configured_requires_switch_and_creds(monkeypatch):