Coverage for tests / asyncapi / confluent / v3_0_0 / base.py: 67%

3 statements  

« prev     ^ index     » next       coverage.py v7.13.5, created at 2026-05-08 01:48 +0000

1from faststream.confluent import KafkaBroker 

2from faststream.specification.base.specification import Specification 

3from tests.asyncapi.base.v3_0_0 import get_3_0_0_spec 

4 

5 

6class AsyncAPI30Mixin: 

7 def get_schema(self, broker: KafkaBroker) -> Specification: 

8 return get_3_0_0_spec(broker)