diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py b/task-sdk/src/airflow/sdk/execution_time/supervisor.py index 176366fbda19e..206bf3b687802 100644 --- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py +++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py @@ -1800,10 +1800,10 @@ def process_log_messages_from_subprocess( # TODO: convert the dict back to a pretty stack trace event["error_detail"] = exc - level = NAME_TO_LEVEL[event.pop("level")] - msg = event.pop("event", None) - for target in loggers: - target.log(level, msg, **event) + if level := NAME_TO_LEVEL.get(event.pop("level")): + msg = event.pop("event", None) + for target in loggers: + target.log(level, msg, **event) def forward_to_log(