diff --git a/src/faststream_fastapi/faststream_api.py b/src/faststream_fastapi/faststream_api.py index 5746aff..08cc5fd 100644 --- a/src/faststream_fastapi/faststream_api.py +++ b/src/faststream_fastapi/faststream_api.py @@ -101,7 +101,7 @@ def __init__( subscriber._call_decorators = ( _subscriber_compatibility_wrapper( config=self._config, - context=self._startable_application.context, + context=broker.context, dependencies=dependencies, # type: ignore[arg-type] ), *subscriber._call_decorators,