Can't create asyncapi docs for nested Pydantic models #867

dumpler · 2023-10-18T18:43:19Z

dumpler
Oct 18, 2023

Hello, the problem is that when using nested Pydantic models, I get the error "Error: Token "$defs"does not exist." when generating AsyncAPI documentation. What am I doing wrong or is it a bug?

Source code

from fastapi import FastAPI

from faststream import Logger
from faststream.kafka import KafkaBroker
from faststream.kafka.fastapi import KafkaRouter
from pydantic import BaseModel

router = KafkaRouter()
router.broker = KafkaBroker("localhost:9094")
logger = Logger("test")
app = FastAPI(lifespan=router.lifespan_context)


class Foo(BaseModel):
    bar: str


class Baz(BaseModel):
    foo: Foo


@router.subscriber("in")
@router.publisher("out")
async def handle(baz: Baz):
    logger.info(baz)
    return "Response"


@router.subscriber("out")
async def handle_response(baz: Baz):
    logger.info(baz)


if __name__ == "__main__":
    uvicorn.run(app, port=8000, host="0.0.0.0", log_level="info")

Expected behavior
Correct AsyncAPI page, but I'm not sure if my code is correct

Observed behavior
Get "Error: Token "$defs"does not exist." at 0.0.0.0:8000/asyncapi

Environment
python = "3.11"
fastapi = "0.104.0"
faststream = {extras = ["kafka"], version = "0.2.5"}
pydantic = "2.4.2"
uvicorn = "0.23.2"