main.py

from fastapi import FastAPI
import inngest

import inngest.fast_api

from app.config.settings import settings
from app.inngest_client import inngest_client

from app.schemas import ResearchRequest

from app.workflows.research_workflow import research_loop

app = FastAPI(title="Python AutoResearch")

@app.get("/")
async def health() -> dict[str, str]:
    return {"status": "ok"}

@app.post("/research")

async def start_research(payload: ResearchRequest) -> dict:
    event = inngest.Event(
        name= "research/requested",
        data= payload.model_dump(),
    )

    event_ids = await inngest_client.send(event)
    return {"queued": True, "event_ids": event_ids}

inngest.fast_api.serve(app, inngest_client, [research_loop])