coverage: 94.584% (-0.04%) from 94.62%
when pulling b414ef7 on AndrianEquestrian:better-fast-stream-depends-integration
into f2da51e on ets-labs:develop.

Thanks for contribution!

With raw Depends it doesn't work in FastStream.
Such test:

@broker.subscriber("hello_world")
@inject
async def on_hello_world(
    input: Input,
    service: Service=Depends(Provide["service"]),
):
    print(f"Service: {service}")

Crashes with an error:

pydantic_core._pydantic_core.ValidationError: 1 validation error for ResponseModel
response
  Input should be a valid dictionary or instance of ResponseModel [type=model_type, input_value=<dependency_injector.wiri...bject at 0x78deeb6cdf70>, input_type=Provide]

But with cast=False all works fine:

@broker.subscriber("hello_world")
@inject
async def on_hello_world(
    input: Input,
    service: Service=Depends(Provide["service"], cast=False),
):
    print(f"Service: {service}")

With raw Depends it doesn't work in FastStream. Such test:

@broker.subscriber("hello_world")
@inject
async def on_hello_world(
    input: Input,
    service: Service=Depends(Provide["service"]),
):
    print(f"Service: {service}")

Crashes with an error:

pydantic_core._pydantic_core.ValidationError: 1 validation error for ResponseModel
response
  Input should be a valid dictionary or instance of ResponseModel [type=model_type, input_value=<dependency_injector.wiri...bject at 0x78deeb6cdf70>, input_type=Provide]

But with cast=False all works fine:

@broker.subscriber("hello_world")
@inject
async def on_hello_world(
    input: Input,
    service: Service=Depends(Provide["service"], cast=False),
):
    print(f"Service: {service}")

Thank You for the observation! Please, include source where you import broker decorator from, I think I should investigate it, in order to determine the cause of the issue.

There was a kafka broker in my test: broker = KafkaBroker("localhost:32833")

Actually, this issue can only be repeated with the FastDepends only by adding @fast_depends.inject:

@fast_depends.inject
@inject
async def apply_coefficient(
    a: int,
    b: str,
    coefficient_provider: CoefficientService = Depends(
        Provide[Container.service]
    ),
) -> float:
    return a * coefficient_provider.get_coefficient()

And now it crashes with the same error: pydantic_core._pydantic_core.ValidationError: 1 validation error for ResponseModel ...