Upload app.py

app.py

@@ -113,6 +113,17 @@ def t5_update_trigger(background_tasks: BackgroundTasks):
     
     return {"status": "triggered", "message": "T5 update pipeline started in the background."}
 
+@app.post("/t5/generate-now")
+def force_t5_generation(background_tasks: BackgroundTasks):
+    """Force T5 prediction generation immediately, bypassing time checks."""
+    background_tasks.add_task(run_t5_pipeline)
+    return {
+        "status": "triggered",
+        "message": "T5 generation forced. Check /t5/predictions for results.",
+        "trigger_time": datetime.now(IST).isoformat(),
+    }
+
+
 # ── NEW: NIFTY 50 Multi-Tier Forecaster Endpoints ─────────────────────────────
 
 @app.get("/nifty50")