fixed all errors

app/core/event_hub.py

@@ -5,7 +5,7 @@ and read recent stream entries without importing `redis` directly.
 """
 import json
 from datetime import datetime
-from typing import Any, Dict, List
+from typing import Any, Dict
 
 from app.deps import get_redis
 

app/main.py

@@ -11,7 +11,6 @@ import subprocess
 import asyncio
 import threading
 import pathlib 
-from datetime import datetime, timedelta
 
 # ─── Third-Party ──────────────────────────────────────────────────────────────
 from fastapi import FastAPI, Depends, HTTPException, Request, Query, BackgroundTasks,json

app/mapper.py

@@ -5,8 +5,7 @@ import duckdb
 import pandas as pd
 import numpy as np
 from datetime import datetime, timedelta
-from app.db import get_conn, ensure_raw_table, enforce_schema_contract, transactional_conn,ensure_schema_versions_table
-from app.utils.detect_industry import _ALIAS, detect_industry
+from app.db import get_conn, ensure_raw_table, transactional_conn,ensure_schema_versions_table
 # app/mapper.py (add line 1)
 from app.hybrid_entity_detector import hybrid_detect_entity_type
 import time
@@ -107,7 +106,7 @@ def poll_for_entity(org_id: str, source_id: str, timeout: int = 30) -> dict:
         return entity_info
     
     # 3. Sleep 5 seconds (gives worker time)
-    print(f"[poll] 🔄 First check failed, sleeping 5s...")
+    print("[poll] 🔄 First check failed, sleeping 5s...")
     time.sleep(5.0)
     
     # 4. Second attempt (final)
@@ -119,7 +118,7 @@ def poll_for_entity(org_id: str, source_id: str, timeout: int = 30) -> dict:
         return entity_info
     
     # 5. Emergency fallback (worker is dead)
-    print(f"[poll] ⚠️ Both attempts failed - using direct detection")
+    print("[poll] ⚠️ Both attempts failed - using direct detection")
     return _fallback_detection(org_id, source_id)
 
 
@@ -139,7 +138,7 @@ def _fallback_detection(org_id: str, source_id: str) -> dict:
         """).fetchall()
     
     if not rows:
-        print(f"[fallback] ❌ No data found, returning UNKNOWN")
+        print("[fallback] ❌ No data found, returning UNKNOWN")
         entity_info = {"entity_type": "UNKNOWN", "confidence": 0.0}
     else:
         parsed = [json.loads(r[0]) for r in rows if r[0]]
@@ -185,7 +184,7 @@ def poll_for_industry(org_id: str, source_id: str, timeout: int = 10) -> dict:
         return industry_info
     
     # 3. Sleep 5 seconds (gives worker time)
-    print(f"[poll_industry] 🔄 First check failed, sleeping 5s...")
+    print("[poll_industry] 🔄 First check failed, sleeping 5s...")
     time.sleep(5.0)
     
     # 4. Second attempt (final)
@@ -197,7 +196,7 @@ def poll_for_industry(org_id: str, source_id: str, timeout: int = 10) -> dict:
         return industry_info
     
     # 5. Emergency fallback (worker is dead)
-    print(f"[poll_industry] ⚠️ Both attempts failed - using direct detection")
+    print("[poll_industry] ⚠️ Both attempts failed - using direct detection")
     return _fallback_industry_detection(org_id, source_id)
     #fallback industry detection
 def _fallback_industry_detection(org_id: str, source_id: str) -> dict:
@@ -218,7 +217,7 @@ def _fallback_industry_detection(org_id: str, source_id: str) -> dict:
         """).fetchall()
         
         if not rows:
-            print(f"[fallback_industry] ❌ No data found, returning UNKNOWN")
+            print("[fallback_industry] ❌ No data found, returning UNKNOWN")
             industry_info = {"industry": "UNKNOWN", "confidence": 0.0}
         else:
             parsed = [json.loads(r[0]) for r in rows if r[0]]

app/routers/analytics_stream.py

@@ -1,14 +1,9 @@
 # app/routers/analytics_stream.py
 from fastapi import APIRouter, HTTPException, Query,BackgroundTasks, Body, Depends
 from typing import List, Dict
-import json
-import asyncio
 from datetime import datetime
 import logging
-from app.deps import get_current_user,APP_URL
-from app.core.event_hub import event_hub
-import uuid
-from app.qstash_client import publish_message, is_qstash_available
+from app.deps import get_current_user
 from app.core.event_hub import event_hub
 logger = logging.getLogger(__name__)
 router = APIRouter(prefix="/api/v1/analytics/stream", tags=["analytics"])

app/routers/datasources.py

@@ -1,16 +1,14 @@
-from fastapi import APIRouter, Query, Form, File, UploadFile, Depends, HTTPException
+from fastapi import APIRouter, Query, Depends, HTTPException
 from typing import Dict, Any, List, Union 
 from fastapi.responses import JSONResponse
 from pydantic import BaseModel
-from typing import List, Any, Dict, Union
 from app.deps import verify_api_key,get_current_user
-from app.db import get_conn, ensure_raw_table, bootstrap
+from app.db import bootstrap
 from app.mapper import canonify_df
 from app.routers.socket import sio
 import pandas as pd
 import json
-import time
-from datetime import datetime, timedelta
+from datetime import datetime
 from app.core.event_hub import event_hub
 import logging
 logger = logging.getLogger(__name__)  

app/schemas/org_schema.py

@@ -1,8 +1,7 @@
 # app/schemas/org_schema.py
-from typing import Dict, Optional, List, Set, Any, Tuple
+from typing import Dict, Optional, List, Tuple
 import json
 import logging
-from datetime import datetime
 from app.core.event_hub import event_hub
 from app.service.llm_service import LocalLLMService
 from app.service.vector_service import VectorService  # Your existing vector service

app/service/llm_service.py

@@ -4,7 +4,6 @@ from transformers import AutoModelForCausalLM, AutoTokenizer, pipeline
 from app.deps import HF_API_TOKEN
 import logging
 from threading import Thread, Lock
-import time
 import json
 import os 
 # redis access not required here; use event_hub if needed

app/tasks/worker.py

@@ -11,7 +11,6 @@ from app.core.event_hub import event_hub
 from app.service.ai_service import ai_service
 from app.deps import get_duckdb
 from app.hybrid_entity_detector import hybrid_detect_entity_type, hybrid_detect_industry_type
-from app.utils.detect_industry import detect_industry as rule_based_detect
 
 # ── Graceful Shutdown ──────────────────────────────────────────────────────────
 def shutdown(signum, frame):