This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit aaeb727636d89f1590b93024b54cc4747c6d7bb2
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jul 10 00:38:22 2025 +0530
[v3-0-test] Fix log for skipped tasks follow up (#53075) (#53101)
(cherry picked from commit b052f844907e7f3a9e4a3f8826b0f4525fafceb2)
Co-authored-by: Pierre Jeambrun <[email protected]>
---
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 89bdf385ee8..66d3f95f92e 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 @@ class FileTaskHandler(logging.Handler):
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."
