fix(tests): revert to stable strict mode and correct imports (formatted)

Author: hyhmrright

backend/app/db/session.py

@@ -1,20 +1,11 @@
-import os
 from collections.abc import AsyncGenerator, AsyncIterator
 from contextlib import asynccontextmanager
-from typing import Any
 
 from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
-from sqlalchemy.pool import NullPool
 
 from app.core.config import settings
 
-# In CI/Test environments, we disable pooling entirely to prevent
-# "Future attached to a different loop" errors during high-concurrency tests.
-_engine_args: dict[str, Any] = {}
-if os.getenv("CI") or os.getenv("PYTEST_CURRENT_TEST"):
-    _engine_args["poolclass"] = NullPool
-
-engine = create_async_engine(settings.database_url, echo=False, **_engine_args)
+engine = create_async_engine(settings.database_url, echo=False)
 AsyncSessionLocal = async_sessionmaker(engine, expire_on_commit=False)
 
 
@@ -25,7 +16,7 @@ async def get_db() -> AsyncGenerator[AsyncSession]:
 
 @asynccontextmanager
 async def isolated_session() -> AsyncIterator[AsyncSession]:
-    """Isolated session manager for background tasks."""
+    """Context manager for a one-off DB session."""
     async with AsyncSessionLocal() as session:
         try:
             yield session

backend/app/main.py

@@ -21,7 +21,7 @@
 
 @asynccontextmanager
 async def lifespan(app: FastAPI) -> AsyncIterator[None]:
-    """FastAPI 生命周期 management：初始化 Qdrant、MinIO 客户端及调度器。"""
+    """FastAPI 生命周期管理：初始化 Qdrant、MinIO 客户端及调度器。"""
     logger.info("app_startup_begin")
     try:
         # 确保基础设施连接正常
@@ -37,36 +37,29 @@ async def lifespan(app: FastAPI) -> AsyncIterator[None]:
         await stop_scheduler()
 
 
-def create_app() -> FastAPI:
-    """App factory to facilitate testing and ensure fresh state."""
-    _app = FastAPI(
-        title="JARVIS API",
-        version="0.1.0",
-        lifespan=lifespan,
-    )
+app = FastAPI(
+    title="JARVIS API",
+    version="0.1.0",
+    lifespan=lifespan,
+)
 
-    # 跨域配置
-    _app.add_middleware(
-        CORSMiddleware,
-        allow_origins=settings.cors_origins,
-        allow_credentials=True,
-        allow_methods=["*"],
-        allow_headers=["*"],
-    )
-    _app.add_middleware(LoggingMiddleware)
+# 跨域配置
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=settings.cors_origins,
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+app.add_middleware(LoggingMiddleware)
 
-    # 监控配置
-    Instrumentator().instrument(_app).expose(_app)
+# 监控配置
+Instrumentator().instrument(app).expose(app)
 
-    # 注册路由
-    _app.include_router(api_router)
+# 注册路由
+app.include_router(api_router)
 
-    @_app.get("/health")
-    async def health() -> dict[str, str]:
-        return {"status": "ok"}
 
-    return _app
-
-
-# Default instance for production/uvicorn
-app = create_app()
+@app.get("/health")
+async def health() -> dict[str, str]:
+    return {"status": "ok"}

backend/pyproject.toml

@@ -136,5 +136,7 @@ module = "app.api.cron"
 disable_error_code = ["import-untyped"]
 
 [tool.pytest.ini_options]
-addopts = "-p no:asyncio"
+asyncio_mode = "strict"
+asyncio_default_test_loop_scope = "session"
+asyncio_default_fixture_loop_scope = "session"
 testpaths = ["tests"]

backend/tests/conftest.py

@@ -6,47 +6,28 @@
 import pytest
 from sqlalchemy.pool import NullPool
 
-# --- ANYIO BACKEND ---
-
-
-@pytest.fixture
-def anyio_backend():
-    """Force anyio to use asyncio."""
-    return "asyncio"
-
-
-# --- INFRASTRUCTURE MOCKS ---
-
-
-@pytest.fixture(autouse=True)
-def mock_infra():
-    """Mock background infrastructure."""
-    with (
-        patch("app.infra.qdrant.get_qdrant_client", AsyncMock()),
-        patch("app.infra.minio.get_minio_client", MagicMock()),
-        patch("redis.asyncio.Redis.from_url", return_value=AsyncMock()),
-        patch("arq.create_pool", return_value=AsyncMock()),
-        patch("app.scheduler.runner.start_scheduler", AsyncMock()),
-        patch("app.scheduler.runner.stop_scheduler", AsyncMock()),
-        patch("apscheduler.schedulers.asyncio.AsyncIOScheduler.start", MagicMock()),
-    ):
-        yield
+# --- GLOBAL MOCKS ---
 
+patch("slowapi.Limiter.limit", lambda *args, **kw: lambda f: f).start()
+patch("app.infra.qdrant.get_qdrant_client", AsyncMock()).start()
+patch("app.infra.minio.get_minio_client", MagicMock()).start()
+patch("redis.asyncio.Redis.from_url", return_value=AsyncMock()).start()
+patch("arq.create_pool", return_value=AsyncMock()).start()
+patch("app.scheduler.runner.start_scheduler", AsyncMock()).start()
+patch("app.scheduler.runner.stop_scheduler", AsyncMock()).start()
 
 # --- APP AND DB FIXTURES ---
 
 from app.db.session import get_db
-from app.main import create_app
+from app.main import app
 
+# Disable lifespan
+app.router.lifespan_context = MagicMock()
 
-@pytest.fixture
-def app():
-    """Fresh app per test."""
-    _app = create_app()
-    _app.router.lifespan_context = MagicMock()
-    if not hasattr(_app, "load_all_plugins"):
-        _app.load_all_plugins = MagicMock()
-    return _app
+
+@pytest.fixture(scope="session")
+def anyio_backend():
+    return "asyncio"
 
 
 @pytest.fixture(scope="session")
@@ -112,7 +93,7 @@ async def db_session(engine):
 
 
 @pytest.fixture
-async def client(app, db_session):
+async def client(db_session):
     async def _override():
         yield db_session