removed socket import

app/routers/datasources.py

@@ -5,7 +5,6 @@ from pydantic import BaseModel
 from app.deps import verify_api_key
 from app.db import bootstrap
 from app.mapper import canonify_df
-from app.routers.socket import sio
 import pandas as pd
 import json
 from datetime import datetime
@@ -80,19 +79,7 @@ async def create_source_json(
         preview_rows = preview_df.to_dict("records") if not preview_df.empty else []
 
         
-        # 4. 📡 Broadcast to connected dashboards
-        await sio.emit(
-            "datasource:new-rows", 
-            {
-                "rows": preview_rows,
-                "industry": industry,
-                "confidence": confidence,
-                "totalRows": len(df),
-                "datasourceId": sourceId,
-            }, 
-            room=orgId
-        )
-
+        
         # 5. ✅ Return comprehensive response
         return JSONResponse(
             status_code=200,