From e54a1d34807d779d449bcfca2665f017f2f92fd1 Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Wed, 18 Jun 2025 13:36:43 +0100 Subject: [PATCH] Fix EOF dection of subprocesses in Dag Processor This should have been handled in #51699 but was missed there as it is very infrequently hit. --- 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 8af35af62b7ef..36b1bf3e478b2 100644 --- a/airflow-core/src/airflow/dag_processing/manager.py +++ b/airflow-core/src/airflow/dag_processing/manager.py @@ -396,7 +396,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: sock: socket = key.fileobj # type: ignore[assignment]