diff --git a/shared/logging/src/airflow_shared/logging/structlog.py b/shared/logging/src/airflow_shared/logging/structlog.py index 2d901b83031d3..9e36d285baf85 100644 --- a/shared/logging/src/airflow_shared/logging/structlog.py +++ b/shared/logging/src/airflow_shared/logging/structlog.py @@ -543,7 +543,7 @@ def is_atty(): ) config["root"] = { "handlers": ["default"], - "level": "INFO", + "level": log_level.upper(), "propagate": True, } diff --git a/shared/logging/tests/logging/test_structlog.py b/shared/logging/tests/logging/test_structlog.py index 08d31b2ffe3fe..4755506190e62 100644 --- a/shared/logging/tests/logging/test_structlog.py +++ b/shared/logging/tests/logging/test_structlog.py @@ -367,3 +367,16 @@ def test_logger_filtering(structlog_config, levels): [other.logger] Hello key1=value4 [my.logger.sub] Hello key1=value5 """) + + +def test_logger_respects_configured_level(structlog_config): + with structlog_config( + colors=False, + log_format="[%(name)s] %(message)s", + log_level="DEBUG", + ) as sio: + my_logger = logging.getLogger("my_logger") + my_logger.debug("Debug message") + + written = sio.getvalue() + assert "[my_logger] Debug message\n" in written