Skip to content

include task instance id in log printed by supervisor#56383

Merged
hussein-awala merged 3 commits intoapache:mainfrom
rawwar:kalyan/task_sdk/print_ti_id_supervisor
Oct 4, 2025
Merged

include task instance id in log printed by supervisor#56383
hussein-awala merged 3 commits intoapache:mainfrom
rawwar:kalyan/task_sdk/print_ti_id_supervisor

Conversation

@rawwar
Copy link
Copy Markdown
Contributor

@rawwar rawwar commented Oct 4, 2025

Currently, when a task finishes, the supervisor log does not provide any information about which task it is related to. Therefore, this PR includes the task instance ID. Ideally, I think the external ID makes sense here in the case of the Celery executor. However, across executors, the task instance ID makes sense.

Log before change:

2025-10-04T03:24:40.460195Z [info     ] Task finished  [supervisor] duration=1.8142216550004377 exit_code=0 final_state=failed loc=supervisor.py:1889

Log after change:

2025-10-04T07:22:01.924062Z [info     ] Task finished  [supervisor] duration=2.9439707239998825 exit_code=-9 final_state=failed loc=supervisor.py:1891 task_instance_id=0199ae19-4f9a-709e-8af4-6b17ecca57c2

@eladkal eladkal added this to the Airflow 3.1.1 milestone Oct 4, 2025
@hussein-awala hussein-awala merged commit 3a93f9b into apache:main Oct 4, 2025
81 checks passed
dabla pushed a commit to dabla/airflow that referenced this pull request Oct 12, 2025
* include task instance id in log printed by supervisor

* fix test
kaxil pushed a commit that referenced this pull request Oct 21, 2025
* include task instance id in log printed by supervisor

* fix test

(cherry picked from commit 3a93f9b)
TyrellHaywood pushed a commit to TyrellHaywood/airflow that referenced this pull request Oct 22, 2025
* include task instance id in log printed by supervisor

* fix test
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants