added loging on datasource and removed kpi computation trigger

.vscode/settings.json

@@ -1,4 +1,14 @@
 {
     "python-envs.defaultEnvManager": "ms-python.python:system",
-    "python-envs.pythonProjects": []
-}
+    "python-envs.pythonProjects": [],
+    
+  "python.linting.enabled": true,
+  "python.linting.ruffEnabled": true,
+  "[python]": {
+    "editor.codeActionsOnSave": {
+      "source.fixAll.ruff": true
+    },
+    "editor.defaultFormatter": "charliermarsh.ruff"
+  }
+}
+

app/routers/datasources.py

@@ -3,7 +3,7 @@ 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,APP_URL
+from app.deps import verify_api_key,get_current_user
 from app.db import get_conn, ensure_raw_table, bootstrap
 from app.mapper import canonify_df
 from app.routers.socket import sio
@@ -12,9 +12,7 @@ import json
 import time
 from datetime import datetime, timedelta
 from app.redis_client import redis 
-# Add this import
-from app.qstash_client import get_qstash_client, is_qstash_available
-# import logging
+import logging
 logger = logging.getLogger(__name__)  
 
 router = APIRouter(tags=["datasources"])  
@@ -83,35 +81,7 @@ async def create_source_json(
 
         preview_rows = preview_df.to_dict("records") if not preview_df.empty else []
 
-        try:
-            # Use APP_URL from deps (no need for settings)
-            trigger_data = {
-                "type": "kpi_compute",
-                "org_id": org_id,
-                "source_id": source_id
-            }
-    
-            # Try QStash if available
-            if is_qstash_available():
-                try:
-                    from app.qstash_client import get_qstash_client
-                    client = get_qstash_client()
-                    result = client.message.publish(
-                        url=f"{APP_URL}/api/v1/analytics/callback",
-                        body=trigger_data
-                    )
-                    logger.info(f"📤 QStash queued: {result.message_id}")
-                except Exception as e:
-                    logger.warning(f"⚠️ QStash failed, using Redis: {e}")
-                    redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
-            else:
-               # ✅ Fallback: Direct Redis publish
-               redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
-               logger.info("📡 Redis fallback for analytics trigger")
-
-        except Exception as e:
-            logger.warning(f"⚠️ Analytics trigger failed (non-critical): {e}")
-            # ✅ DON'T raise - ingestion should succeed even if analytics fails
+        
         # 4. 📡 Broadcast to connected dashboards
         await sio.emit(
             "datasource:new-rows",