Saddala opened a new pull request, #65002:
URL: https://github.com/apache/airflow/pull/65002
After SIGKILL, stale socket registrations on the shared selector cause the
next `select()` callback to write to an already-closed `BytesLogger` handle,
raising `ValueError: write to closed file` and crashing the entire
`DagProcessorJob`.
- Add `_deregister_processor_sockets()` to unregister and close all sockets
for a killed processor before `logger_filehandle.close()` is called. Applied in
both `terminate_orphan_processes` and `_kill_timed_out_processors`.
- Guard `target.log()` in `process_log_messages_from_subprocess` with a
`ValueError` catch that discards remaining buffered output cleanly.
closes: #64959
---
--
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]
