From 9354588ba2d853bd71e3af6a43d6c589d8a6605f Mon Sep 17 00:00:00 2001
From: guke <guke@autohome.com.cn>
Date: Mon, 6 Jul 2026 11:14:52 +0800
Subject: [PATCH] =?UTF-8?q?style(observe):=20=E5=8E=BB=E5=86=97=E4=BD=99?=
 =?UTF-8?q?=E6=B3=A8=E8=A7=A3=E5=BC=95=E5=8F=B7=20+=20=E6=95=B4=E7=90=86?=
 =?UTF-8?q?=20import(ruff=20UP037/I001)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
---
 app/core/observe.py   | 4 ++--
 tests/test_observe.py | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

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):