server.py

app = FastAPI()
dr = driver.Driver(
    {"mode": "online"},
    aggregations,
    data_loaders,
    joins,
    features,
    model,
    adapter=base.DefaultAdapter(),
)


@app.get("/predict")
def get_prediction(client_id: int) -> float:
    series_out = dr.execute(
        ["predictions"], inputs={"client_id": client_id, "execution_time": datetime.now()}
    )["predictions"]
    return series_out.values[0]