(airflow) branch v3-1-test updated: [v3-1-test] Fix Dag Processor logging crash (#59317) (#59581)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/v3-1-test by this push:
     new 1624a400c73 [v3-1-test] Fix Dag Processor logging crash (#59317) 
(#59581)
1624a400c73 is described below

commit 1624a400c73300c97bae53702bd6f338563b9e21
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Dec 17 19:46:31 2025 +0100

    [v3-1-test] Fix Dag Processor logging crash (#59317) (#59581)
    
    (cherry picked from commit 1c0b4936d4063e65515669c5cebbe267c1ad18ce)
    
    Co-authored-by: Marcin Szymański <ms32...@gmail.com>
---
 task-sdk/src/airflow/sdk/execution_time/supervisor.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py 
b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
index 176366fbda1..206bf3b6878 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(