Update app/routes/pipeline.py

app/routes/pipeline.py

@@ -1,5 +1,7 @@
 # app/routes/pipeline.py
 
+import os
+import requests
 from fastapi import APIRouter, Depends, Query
 from datetime import datetime
 from agent_manager import AgentManager
@@ -12,6 +14,8 @@ router = APIRouter(
     dependencies=[Depends(require_api_key)]
 )
 
+WEBHOOK_URL = os.getenv("ZAPIER_WEBHOOK")  # Set this in HF Secrets
+
 @router.on_event("startup")
 def startup_db():
     init_db()
@@ -23,12 +27,21 @@ def run_pipeline(
 ):
     manager = AgentManager(niche, business_type)
     summary = manager.run_all()
+    # Log each step
     for agent_name, result in summary.items():
         log_action(agent_name, "pipeline_run", result)
-    return {
-        "status": "pipeline_executed",
+    payload = {
         "niche": niche,
         "business_type": business_type,
         "results": summary,
         "timestamp": datetime.utcnow().isoformat()
     }
+    # Fire the Zapier webhook (non‑blocking)
+    try:
+        requests.post(WEBHOOK_URL, json=payload, timeout=2)
+    except Exception:
+        pass
+    return {
+        "status": "pipeline_executed",
+        **payload
+    }