DaveT1991 opened a new pull request, #64996: URL: https://github.com/apache/airflow/pull/64996
## Summary Prevent DAG processor crashes when late subprocess log events arrive after a DAG file processor's log file handle has already been closed. `process_log_messages_from_subprocess()` currently forwards every decoded log event directly to each configured logger. During orphan process termination, buffered socket events can still be delivered after the DAG processor has already closed the corresponding BytesLogger file handle, which raises `ValueError: write to closed file` and brings down the whole job. This change treats that specific closed-file logger error as a dropped late log line instead of letting it propagate, and adds regression coverage for the mixed case where one target logger is already closed while another is still able to receive the message. Closes #64959 ## Testing - Added regression coverage in `task-sdk/tests/task_sdk/execution_time/test_supervisor.py` - `git diff --check` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
