From aef4350adedc62292608e5a8292ff9831684c8f6 Mon Sep 17 00:00:00 2001 From: Amogh Desai Date: Wed, 14 May 2025 16:13:07 +0530 Subject: [PATCH] [v3-0-test] Do not flood worker logs with secrets backend loading logs (#50581) (cherry picked from commit e46508b7d8da9f3da7ab5f753f87d356d915aa48) Co-authored-by: Amogh Desai closes: #50517 --- .../src/airflow/sdk/execution_time/supervisor.py | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py b/task-sdk/src/airflow/sdk/execution_time/supervisor.py index 2618cf8a4c3af..d0d7b7d9eb1fe 100644 --- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py +++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py @@ -1450,14 +1450,6 @@ def ensure_secrets_backend_loaded() -> list[BaseSecretsBackend]: backends = ensure_secrets_loaded(default_backends=DEFAULT_SECRETS_SEARCH_PATH_WORKERS) - log = structlog.get_logger(logger_name="supervisor") - - log.info( - "Secrets backends loaded for worker", - count=len(backends), - backend_classes=[type(b).__name__ for b in backends], - ) - return backends @@ -1520,7 +1512,12 @@ def supervise( processors = logging_processors(enable_pretty_log=pretty_logs)[0] logger = structlog.wrap_logger(underlying_logger, processors=processors, logger_name="task").bind() - ensure_secrets_backend_loaded() + backends = ensure_secrets_backend_loaded() + log.info( + "Secrets backends loaded for worker", + count=len(backends), + backend_classes=[type(b).__name__ for b in backends], + ) reset_secrets_masker()