refacroed compute endpoint

app/main.py

@@ -232,11 +232,16 @@ async def add_request_tracking(request: Request, call_next):
 
 # ─── KPI Computation Endpoint ──────────────────────────────────────────────────
 # ─── KPI Computation Endpoint ──────────────────────────────────────────────────
+# At top of app/main.py - add import
+from app.deps import verify_api_key, rate_limit_org
+
+# Replace the compute_kpis function
 @app.post("/api/v1/kpi/compute")
 async def compute_kpis(
-    background_tasks: BackgroundTasks,  # ✅ First parameter, no default needed
+    background_tasks: BackgroundTasks,
+    org_id: str = Query(..., description="Organization ID"),
     source_id: str = Query(..., description="Data source ID"),
-    current_user: dict = Depends(get_current_user),
+    api_key: str = Depends(verify_api_key),  # ✅ Returns string, not HTTPAuthorizationCredentials
     limited_org: str = Depends(rate_limit_org(max_requests=50))
 ):
     """
@@ -244,8 +249,6 @@ async def compute_kpis(
     Returns immediately; results published to Redis stream.
     """
     try:
-        org_id = current_user["org_id"]
-        
         # Check cache first
         cached = event_hub.get_key(f"kpi_cache:{org_id}:{source_id}")
         if cached: