removed background jobs on datasource endpoint

app/routers/datasources.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, Query, Form, File, UploadFile, Depends, HTTPException
+from fastapi import APIRouter, Query, Form, File, UploadFile, Depends, HTTPException,BackgroundTasks
 from typing import Dict, Any, List, Union 
 from fastapi.responses import JSONResponse
 from pydantic import BaseModel
@@ -13,8 +13,8 @@ import time
 from datetime import datetime, timedelta
 from app.redis_client import redis 
 # Add this import
-from app.tasks.analytics_worker import trigger_kpi_computation
 from app.qstash_client import get_qstash_client, is_qstash_available
+  
 router = APIRouter(tags=["datasources"])  # Remove 
 
 
@@ -70,8 +70,7 @@ async def create_source_json(
         #  Entity will be auto-queued by process_detect_industry()
        
         df, industry, confidence = canonify_df(org_id, source_id)
-        # run autokpi computation in background
-        background_tasks.add_task(trigger_kpi_computation, org_id, source_id)
+        
         # Convert DataFrame to JSON-safe format
         preview_df = df.head(3).copy()
         for col in preview_df.columns:

app/tasks/analytics_worker.py

@@ -64,7 +64,7 @@ class AnalyticsWorker:
             
             logger.info(f"[WORKER] 📊 Loaded {len(df)} rows × {len(df.columns)} cols")
             
-            # 2️⃣ SCHEMA DISCOVERY (Einstein's brain)
+            
             # Fast from cache (~0ms), slow on first run (~30s)
             mapping = await self._discover_schema(df)
             if not mapping: