diff --git a/lite_bootstrap/bootstrappers/faststream_bootstrapper.py b/lite_bootstrap/bootstrappers/faststream_bootstrapper.py index 6982525..f4a3fdd 100644 --- a/lite_bootstrap/bootstrappers/faststream_bootstrapper.py +++ b/lite_bootstrap/bootstrappers/faststream_bootstrapper.py @@ -109,8 +109,9 @@ def bootstrap(self) -> None: super().bootstrap() broker = self.bootstrap_config.application.broker if broker is not None and import_checker.is_structlog_installed and import_checker.is_faststream_installed: - broker.config.logger.params_storage = ManualLoggerStorage(structlog.get_logger("faststream")) - broker.config.logger.set_level(self.bootstrap_config.faststream_log_level) + logger = structlog.get_logger("faststream") + logger.setLevel(self.bootstrap_config.faststream_log_level) + broker.config.logger.params_storage = ManualLoggerStorage(logger) @dataclasses.dataclass(kw_only=True, frozen=True) diff --git a/tests/test_faststream_bootstrap.py b/tests/test_faststream_bootstrap.py index 3c174d7..d0dcf1b 100644 --- a/tests/test_faststream_bootstrap.py +++ b/tests/test_faststream_bootstrap.py @@ -99,7 +99,7 @@ def test_faststream_logging_instrument_injects_structlog_logger(broker: RedisBro bootstrapper.bootstrap() try: assert isinstance(broker.config.logger.params_storage, ManualLoggerStorage) - assert broker.config.logger.log_level == logging.WARNING + assert logging.getLogger("faststream").level == logging.WARNING finally: bootstrapper.teardown()