flush()

def flush() -> None

from rdk import init, flush

init()

# Your LLM calls...

# Force send all pending traces
flush()

@app.post("/debug-chat")
@observe(name="debug")
async def debug_chat(request: Request):
    result = await chat(request.message)
    flush()  # See trace immediately
    return result

import atexit
from rdk import flush

atexit.register(flush)

init(flush_interval=999999)  # Effectively disable auto-flush

# Flush when you decide
flush()