(airflow) branch v3-2-test updated: [v3-2-test] Surface LogStreamAccumulator temp-file removal failures as warnings (#66663) (#66669)

[po...@apache.org]

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

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


The following commit(s) were added to refs/heads/v3-2-test by this push:
     new 4e7c568ee17 [v3-2-test] Surface LogStreamAccumulator temp-file removal failures as warnings (#66663) (#66669)
4e7c568ee17 is described below

commit 4e7c568ee17047ecbc15872f879bb95466ae6e19
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Sun May 10 21:08:33 2026 +0200

    [v3-2-test] Surface LogStreamAccumulator temp-file removal failures as warnings (#66663) (#66669)
    
    Failure to remove the spill file is the exact failure mode that
    caused the prior /tmp leak (~39 GB on a single host), so operators
    need it visible in their logs rather than buried at debug level.
    
    Follow-up to #66450.
    (cherry picked from commit 1abd9594cb629d1a47fbc268c1de5a0fb8c78fdb)
    
    Co-authored-by: Dheeraj Turaga <dh...@gmail.com>
---
 airflow-core/src/airflow/utils/log/log_stream_accumulator.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow-core/src/airflow/utils/log/log_stream_accumulator.py b/airflow-core/src/airflow/utils/log/log_stream_accumulator.py
index 343a9f35139..6efd9d444af 100644
--- a/airflow-core/src/airflow/utils/log/log_stream_accumulator.py
+++ b/airflow-core/src/airflow/utils/log/log_stream_accumulator.py
@@ -49,7 +49,7 @@ def _safe_remove(path: str) -> None:
     except FileNotFoundError:
         pass
     except OSError as exc:
-        logger.debug("LogStreamAccumulator: could not remove temp file %s: %s", path, exc)
+        logger.warning("LogStreamAccumulator: could not remove temp file %s: %s", path, exc)
 
 
 class LogStreamAccumulator: