From 4112fd2e2042f41529ee77b8fc357a20cb245022 Mon Sep 17 00:00:00 2001 From: pierrejeambrun Date: Wed, 9 Jul 2025 10:41:35 +0200 Subject: [PATCH] Fix log for skipped tasks follow up --- airflow-core/src/airflow/utils/log/file_task_handler.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow-core/src/airflow/utils/log/file_task_handler.py b/airflow-core/src/airflow/utils/log/file_task_handler.py index 9b086457f604d..6ee087c385896 100644 --- a/airflow-core/src/airflow/utils/log/file_task_handler.py +++ b/airflow-core/src/airflow/utils/log/file_task_handler.py @@ -483,7 +483,7 @@ def read( if try_number is None: try_number = task_instance.try_number - if task_instance.state == TaskInstanceState.SKIPPED: + if try_number == 0 and task_instance.state == TaskInstanceState.SKIPPED: logs = [ StructuredLogMessage( # type: ignore[call-arg] event="Task was skipped, no logs available."