corrected org_schema

app/core/worker_manager.py

@@ -1,5 +1,4 @@
 import asyncio
-import json
 from app.core.event_hub import event_hub
 from app.tasks.analytics_worker import AnalyticsWorker
 import logging

app/routers/schema.py

@@ -2,7 +2,7 @@
 from fastapi import APIRouter, Depends
 from app.deps import get_current_user
 from typing import Dict 
-from app.service.schema_service import OrgSchema
+from app.service.schema_service import Org_Schema
 router = APIRouter(prefix="/api/v1/schema", tags=["schema"])
 
 @router.get("/discover")
@@ -11,7 +11,7 @@ async def discover_schema(
 ):
     org_id = current_user["org_id"] 
     """Return column mappings for this org"""
-    schema = OrgSchema(org_id)
+    schema = Org_Schema(org_id)
     return schema.get_mapping()
 
 @router.post("/override")
@@ -22,6 +22,6 @@ async def override_schema(
     org_id = current_user["org_id"]  # Then extract inside function
 
     """Allow manual column mapping override"""
-    schema = OrgSchema(org_id)
+    schema = Org_Schema(org_id)
     schema.save_mapping(mapping)
     return {"status": "saved", "mapping": mapping}