fix(lint): resolve ruff code formatting and unused import warnings

src/agent/nodes/classify_agent.py

@@ -1,6 +1,5 @@
 import mlflow
 import os
-import re
 import structlog
 from typing import List
 from src.agent.state import AgentState

src/api/routers/metrics.py

@@ -32,7 +32,6 @@ WHY COUNTERS AND HISTOGRAMS?
 
 from __future__ import annotations
 
-import time
 
 from fastapi import APIRouter
 from fastapi.responses import PlainTextResponse

src/api/routers/triage.py

@@ -7,7 +7,6 @@ Replaces the in-memory triage_store with TicketRepository.
 
 from __future__ import annotations
 
-import asyncio
 from datetime import datetime, timezone
 from typing import Any
 from uuid import UUID, uuid4

src/api/store.py

@@ -29,7 +29,7 @@ import time
 from collections import defaultdict
 from datetime import datetime
 from typing import Any
-from uuid import UUID, uuid4
+from uuid import uuid4
 
 from src.api.models import TriageResultResponse, TriageStatus
 

src/db/repository.py

@@ -39,11 +39,10 @@ ROW LEVEL SECURITY:
 from __future__ import annotations
 
 import os
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from datetime import datetime, timezone
 from typing import Any
 import uuid
-from uuid import UUID
 
 from supabase import AsyncClient, acreate_client
 # ─────────────────────────────────────────────────────────────────────────────
@@ -178,7 +177,6 @@ class TicketRepository:
         if self.use_in_memory or os.getenv("APP_ENV") == "test":
             return self.tenant_id
 
-        import uuid
         try:
             uuid.UUID(self.tenant_id)
             return self.tenant_id

src/rag/graph_rag.py

@@ -47,7 +47,7 @@ Run demo:
 import logging
 from collections import defaultdict
 from dataclasses import dataclass, field
-from typing import Optional, Any
+from typing import Optional
 
 logger = logging.getLogger(__name__)
 

src/rag/hybrid_retriever.py

@@ -37,7 +37,7 @@ Run standalone demo:
 import hashlib
 import logging
 import time
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Optional
 
 logger = logging.getLogger(__name__)

src/rag/llm_client.py

@@ -26,7 +26,7 @@ Environment variables:
 import os
 import time
 import logging
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Optional, Any
 
 try:

src/rag/multilingual.py

@@ -37,7 +37,6 @@ write in French. Routing all tickets through an English-only model:
 
 import logging
 import re
-from typing import Optional
 
 logger = logging.getLogger(__name__)
 
@@ -94,7 +93,7 @@ def detect_language(text: str, min_text_length: int = 20) -> str:
         return "en"  # too short for reliable detection
 
     try:
-        from langdetect import detect, LangDetectException
+        from langdetect import detect
         lang = detect(text)
         # langdetect returns e.g. "zh-cn" — normalize to first part
         lang = lang.split("-")[0].lower()
@@ -116,7 +115,7 @@ def detect_language_with_confidence(text: str) -> tuple[str, float]:
         return "en", 1.0
 
     try:
-        from langdetect import detect_langs, LangDetectException
+        from langdetect import detect_langs
         results = detect_langs(text)
         if results:
             top = results[0]

src/rag/router.py

@@ -40,8 +40,6 @@ Run standalone demo:
 """
 
 import logging
-import os
-import time
 from dataclasses import dataclass, field
 from typing import Literal, Optional
 from collections import defaultdict

src/responsible_ai/audit_log.py

@@ -20,7 +20,6 @@ Run standalone check:
 import hashlib
 import json
 import logging
-import os
 from datetime import datetime, timezone
 from pathlib import Path
 from typing import Literal

src/responsible_ai/privacy_vault.py

@@ -39,10 +39,8 @@ Run standalone demo:
   python -m src.responsible_ai.privacy_vault
 """
 
-import os
 import re
 import sqlite3
-import hashlib
 from datetime import datetime, timezone
 from pathlib import Path
 from typing import Optional
@@ -438,5 +436,5 @@ if __name__ == "__main__":
     except PermissionError as e:
         print(f"  BLOCKED: {e}")
 
-    print(f"\nAudit log written to: logs/vault_audit/audit_trail.jsonl")
+    print("\nAudit log written to: logs/vault_audit/audit_trail.jsonl")
     print("=" * 60)

src/streaming/bronze_consumer.py

@@ -15,7 +15,6 @@ import argparse
 import io
 import json
 import signal
-import sys
 import time
 from collections import defaultdict
 from datetime import datetime, timezone
@@ -165,7 +164,7 @@ def main(batch_size: int = 500, timeout_seconds: int = 30):
     print(f"  Parquet files  : {files_written}")
     print(f"  Duration       : {elapsed:.1f}s")
     print(f"  Sink           : s3://{BUCKET}/bronze/")
-    print(f"  Browse MinIO   : http://localhost:9001")
+    print("  Browse MinIO   : http://localhost:9001")
     print(f"{'=' * 60}")
 
 

src/streaming/bronze_to_silver.py

@@ -267,9 +267,9 @@ def main(source: str = "tickets", limit: int = None, use_vault: bool = True):
     if use_vault and _VAULT_AVAILABLE:
         from src.responsible_ai.privacy_vault import CryptographicPrivacyVault
         vault = CryptographicPrivacyVault()
-        print(f"  Privacy Vault: ENABLED (AES-256, silver_version=2.0)")
+        print("  Privacy Vault: ENABLED (AES-256, silver_version=2.0)")
     else:
-        print(f"  Privacy Vault: DISABLED (legacy Presidio masking, silver_version=1.0)")
+        print("  Privacy Vault: DISABLED (legacy Presidio masking, silver_version=1.0)")
 
     # ── 4. Clean + mask PII ───────────────────────────────────
     print(f"\n[4/5] Cleaning and masking PII in {len(all_records):,} records...")

src/streaming/data_loader.py

@@ -45,7 +45,7 @@ import uuid
 from datetime import datetime, timezone
 
 from confluent_kafka import Producer
-from datasets import load_dataset, concatenate_datasets
+from datasets import load_dataset
 from tqdm import tqdm
 
 # ── Config ────────────────────────────────────────────────────
@@ -286,10 +286,10 @@ def main(limit: int = None, delay: float = 0.0, sources: str = "all"):
 
     # ── 1. Download datasets ──────────────────────────────────
     print("\n[1/3] Downloading datasets from Hugging Face...")
-    t_start = time.time()
+    time.time()
     all_rows, source_counts = load_sources(sources)
 
-    print(f"\n  Source breakdown:")
+    print("\n  Source breakdown:")
     for src, count in source_counts.items():
         print(f"    {src:18s}: {count:,} rows")
     total = len(all_rows)
@@ -351,7 +351,7 @@ def main(limit: int = None, delay: float = 0.0, sources: str = "all"):
     print(f"  Duration    : {elapsed:.1f}s  ({len(all_rows)/elapsed:.0f} msg/s)")
     print(f"  Topic       : {TOPIC}")
     print(f"  Sources     : {sources}")
-    print(f"  Language breakdown:")
+    print("  Language breakdown:")
     for lang, count in sorted(lang_counts.items()):
         print(f"    {lang}: {count:,} rows")
     print(f"{'=' * 65}")

src/streaming/minio_setup.py

@@ -59,7 +59,7 @@ def setup():
         print(f"  [OK] {BUCKET}/{prefix}")
 
     print(f"\nLakehouse structure ready at MinIO: {MINIO_ENDPOINT}")
-    print(f"Browse at: http://localhost:9001 (user: minioadmin / pass: minioadmin)")
+    print("Browse at: http://localhost:9001 (user: minioadmin / pass: minioadmin)")
 
 
 if __name__ == "__main__":

src/streaming/triage_consumer.py

@@ -3,7 +3,6 @@ import json
 import logging
 import os
 import signal
-import sys
 from confluent_kafka import Consumer, KafkaError
 from src.api.routers.triage import _run_triage
 from src.db.repository import TicketRepository, TicketRecord