From d0b9084a312a385c200c1a6e3511191319cf5bac Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Wed, 18 Jun 2025 17:29:51 +0100 Subject: [PATCH] [v3-0-test] Fix EOF dection of subprocesses in Dag Processor (#51885) This should have been handled in #51699 but was missed there as it is very infrequently hit. (cherry picked from commit b8b7f4a1121d5bca1110ab358ef0d51536b3133f) Co-authored-by: Ash Berlin-Taylor --- airflow-core/src/airflow/dag_processing/manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow-core/src/airflow/dag_processing/manager.py b/airflow-core/src/airflow/dag_processing/manager.py index c143e682608a6..89a9fbb1aa746 100644 --- a/airflow-core/src/airflow/dag_processing/manager.py +++ b/airflow-core/src/airflow/dag_processing/manager.py @@ -394,7 +394,7 @@ def _service_processor_sockets(self, timeout: float | None = 1.0): # to EOF case try: need_more = socket_handler(key.fileobj) - except BrokenPipeError: + except (BrokenPipeError, ConnectionResetError): need_more = False if not need_more: self.selector.unregister(key.fileobj)