diff --git a/app/core/observe_worker.py b/app/core/observe_worker.py
index 7140359..c037467 100644
--- a/app/core/observe_worker.py
+++ b/app/core/observe_worker.py
@@ -28,7 +28,7 @@ async def _collect_batch() -> list[dict]:
         first = await asyncio.wait_for(
             queue.get(), timeout=settings.OBSERVE_FLUSH_INTERVAL_SEC
         )
-    except TimeoutError:
+    except asyncio.TimeoutError:  # noqa: UP041 - 3.10 兼容:该版 wait_for 抛的 asyncio.TimeoutError ≠ 内置 TimeoutError
         return batch
     batch.append(first)
     while len(batch) < settings.OBSERVE_BATCH_MAX: