added kpi computations triger

app/tasks/analytics_worker.py

@@ -396,11 +396,17 @@ async def redis_listener():
 
 
 # ---- FastAPI Integration ---- #
-# In your main.py:
-"""
-from app.tasks.analytics_worker import redis_listener
-
-@app.on_event("startup")
-async def start_redis_listener():
-    asyncio.create_task(redis_listener(), name="redis-listener")
-"""
+async def trigger_kpi_computation(org_id: str, source_id: str):
+    """Trigger the worker via Redis pubsub"""
+    try:
+        redis.publish(
+            f"analytics_trigger:{org_id}:{source_id}",
+            json.dumps({
+                "org_id": org_id,
+                "source_id": source_id,
+                "timestamp": datetime.now().isoformat()
+            })
+        )
+        logger.info(f"🎯 Triggered KPI computation: {org_id}/{source_id}")
+    except Exception as e:
+        logger.error(f"Trigger failed: {e}")