feat: remove unused import

app/api/deps.py

@@ -12,7 +12,6 @@ from app.services.ocr_service import OCRService
 from app.services.sql_validator_service import SqlValidatorService
 from app.services.text_cleaner_service import TextCleanerService
 from app.services.vector_store_service import VectorStoreService
-from app.services.web_search_service import WebSearchService
 
 
 def get_sql_validator_service() -> SqlValidatorService:

app/api/v1/qr_generator.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import threading
-from typing import Any, Dict, List, Optional
+from typing import List, Optional
 
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel, Field, field_validator

app/api/v1/scraper.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import time
-from typing import Optional
 
 from fastapi import APIRouter, Depends
 

app/api/v1/url_shortener.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import threading
-from datetime import datetime, timezone
 from typing import Any, Dict, List, Optional
 
 from fastapi import APIRouter, Depends, Header, HTTPException, Path, Query

app/core/auth/deps.py

@@ -1,17 +1,16 @@
 from __future__ import annotations
 
 import logging
-from typing import Annotated, Any, AsyncGenerator, Optional
+from typing import Annotated, AsyncGenerator, Optional
 
 import jwt
 from argon2 import PasswordHasher
-from argon2.exceptions import VerifyMismatchError
 from fastapi import Depends, HTTPException, Request, status
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
 
 from app.config import get_settings
-from app.core.auth.models import Base, Permission, RefreshSession, Role, User
+from app.core.auth.models import Base, Permission, Role, User
 
 logger = logging.getLogger("auth")
 

app/core/database/base.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import asyncio
-import time
 from abc import ABC, abstractmethod
 from dataclasses import dataclass, field
 from typing import Any

app/core/database/mongodb.py

@@ -5,7 +5,7 @@ from urllib.parse import quote_plus
 
 from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorDatabase
 
-from app.core.database.base import BaseExecutor, ConnectionConfig, StatementResult
+from app.core.database.base import BaseExecutor, StatementResult
 from app.core.logger import get_logger
 
 _logger = get_logger(__name__)

app/core/database/mysql.py

@@ -4,7 +4,7 @@ from typing import Any
 
 import aiomysql
 
-from app.core.database.base import BaseExecutor, ConnectionConfig, StatementResult
+from app.core.database.base import BaseExecutor, StatementResult
 from app.core.logger import get_logger
 
 _logger = get_logger(__name__)

app/core/database/pool.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import asyncio
-from typing import Any
 
 from app.core.database.base import BaseExecutor, ConnectionConfig
 from app.core.database.mysql import MySQLExecutor

app/core/database/postgresql.py

@@ -1,11 +1,10 @@
 from __future__ import annotations
 
 import ssl as ssl_module
-from typing import Any
 
 import asyncpg
 
-from app.core.database.base import BaseExecutor, ConnectionConfig, StatementResult
+from app.core.database.base import BaseExecutor, StatementResult
 from app.core.logger import get_logger
 
 _logger = get_logger(__name__)
@@ -52,7 +51,7 @@ class PostgreSQLExecutor(BaseExecutor):
                 if use_transaction:
                     await tr.commit()
                 return results
-            except Exception as exc:
+            except Exception:
                 if use_transaction:
                     try:
                         await tr.rollback()

app/core/redis_client.py

@@ -5,7 +5,6 @@ from typing import Optional
 
 from redis.asyncio import Redis
 
-from app.config import get_settings
 
 logger = logging.getLogger(__name__)
 

app/core/vector_store/models.py

@@ -2,9 +2,9 @@ from __future__ import annotations
 
 import json
 from datetime import datetime, timezone
-from typing import Any, Dict, Optional
+from typing import Any, Dict
 
-from sqlalchemy import Column, String, Text
+from sqlalchemy import String, Text
 from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column
 
 

app/services/auth_service.py

@@ -3,13 +3,12 @@ from __future__ import annotations
 import hashlib
 import logging
 import secrets
-from datetime import datetime, timedelta, timezone
-from typing import Optional
+from datetime import datetime, timedelta
 
 import jwt
 from argon2 import PasswordHasher
 from argon2.exceptions import VerifyMismatchError
-from fastapi import HTTPException, Request, status
+from fastapi import HTTPException, Request
 from sqlalchemy import select, update
 from sqlalchemy.ext.asyncio import AsyncSession
 

app/services/converter_service.py

@@ -3,7 +3,6 @@ from __future__ import annotations
 import hashlib
 import io
 import mimetypes
-import re
 import time
 from pathlib import Path
 from urllib.parse import urlparse

app/services/database_service.py

@@ -1,10 +1,8 @@
 from __future__ import annotations
 
 import time
-from typing import Any
 
 from app.core.database import ConnectionConfig, pool_manager
-from app.core.database.base import StatementResult
 from app.core.logger import get_logger
 from app.models.schemas import (
     DatabaseQueryError,

app/services/prompt_service.py

@@ -8,7 +8,7 @@ prompts for LLM-based CSV/dataframe analysis and visualization.
 from __future__ import annotations
 
 import json
-from typing import Any, Dict, List, Optional
+from typing import Any, Dict, List
 
 # ---------------------------------------------------------------------------
 # Canned System Prompts

app/services/reconciliation_service.py

@@ -31,12 +31,23 @@ DEFAULT_NUMERIC_KEYWORDS: Set[str] = {
 }
 
 
-class ReconciliationError(Exception): pass
-class DownloadError(ReconciliationError): pass
-class FileTypeMismatchError(ReconciliationError): pass
-class SchemaMismatchError(ReconciliationError): pass
-class EmptyDatasetError(ReconciliationError): pass
-class UnsupportedFormatError(ReconciliationError): pass
+class ReconciliationError(Exception):
+    pass
+
+class DownloadError(ReconciliationError):
+    pass
+
+class FileTypeMismatchError(ReconciliationError):
+    pass
+
+class SchemaMismatchError(ReconciliationError):
+    pass
+
+class EmptyDatasetError(ReconciliationError):
+    pass
+
+class UnsupportedFormatError(ReconciliationError):
+    pass
 
 
 def extract_extension(url: str) -> str:

app/services/semantic_router_service.py

@@ -2,7 +2,7 @@ from __future__ import annotations
 
 import logging
 from collections import defaultdict
-from typing import Any, Optional
+from typing import Any
 
 import numpy as np
 

app/services/url_shortener_service.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import asyncio
 import csv
 import hashlib
 import hmac
@@ -1049,7 +1048,6 @@ class URLShortenerService:
             raise LinkNotFoundError(f"No link found for code '{short_code}'")
         if row["owner_id"] != owner_id:
             raise AuthorizationError("You do not own this link")
-        import sqlite3 as _sqlite3
         rows = self.storage._conn.execute(
             "SELECT id, referrer, user_agent, ip_address, browser, device, os, clicked_at "
             "FROM url_shortener_clicks WHERE short_code = ? ORDER BY clicked_at DESC LIMIT ?",

app/services/vector_store_service.py

@@ -448,7 +448,7 @@ class VectorStoreService:
             _EMBEDDING_DIM,
         )
 
-        elapsed_sync = await self._run_sync_fn(
+        await self._run_sync_fn(
             lambda: self._ingest_document_sync(store_id, doc_id, text, chunks, embeddings, source or "")
         )
 

test_integration.py

@@ -1,8 +1,8 @@
 """Integration tests against running FastAPI server + SearXNG container."""
 
 import json
+import sys
 import urllib.request
-import time
 
 BASE = "http://localhost:8000/api/v1"
 HEADERS = {
@@ -89,5 +89,4 @@ if failed == 0:
 else:
     print("SOME TESTS FAILED")
 
-import sys
 sys.exit(0 if failed == 0 else 1)