diff --git a/airflow-core/src/airflow/jobs/triggerer_job_runner.py b/airflow-core/src/airflow/jobs/triggerer_job_runner.py index d4d49e50f9f51..08ec17fbf8cb9 100644 --- a/airflow-core/src/airflow/jobs/triggerer_job_runner.py +++ b/airflow-core/src/airflow/jobs/triggerer_job_runner.py @@ -710,6 +710,10 @@ def _process_log_messages_from_subprocess(self) -> Generator[None, bytes | bytea import msgspec from structlog.stdlib import NAME_TO_LEVEL + from airflow.sdk.log import configure_logging + + configure_logging() + fallback_log = structlog.get_logger(logger_name=__name__) from airflow.sdk.log import logging_processors