This is an automated email from the ASF dual-hosted git repository.
ash pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 850dbe6ad03 log ti_id when we get back a 404 or 409 on task heartbeat
(#48718)
850dbe6ad03 is described below
commit 850dbe6ad03f8f59ce35f66546290a8a88ff5550
Author: Mehul Goyal <[email protected]>
AuthorDate: Thu Apr 3 00:13:48 2025 -0700
log ti_id when we get back a 404 or 409 on task heartbeat (#48718)
---
task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1 +
task-sdk/tests/task_sdk/execution_time/test_supervisor.py | 1 +
2 files changed, 2 insertions(+)
diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py
b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
index 860756fa06a..a353ffce23c 100644
--- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py
+++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
@@ -850,6 +850,7 @@ class ActivitySubprocess(WatchedSubprocess):
"Server indicated the task shouldn't be running anymore",
detail=e.detail,
status_code=e.response.status_code,
+ ti_id=self.id,
)
self.kill(signal.SIGTERM, force=True)
else:
diff --git a/task-sdk/tests/task_sdk/execution_time/test_supervisor.py
b/task-sdk/tests/task_sdk/execution_time/test_supervisor.py
index 9598c7599e8..64906726219 100644
--- a/task-sdk/tests/task_sdk/execution_time/test_supervisor.py
+++ b/task-sdk/tests/task_sdk/execution_time/test_supervisor.py
@@ -493,6 +493,7 @@ class TestWatchedSubprocess:
"status_code": 409,
"logger": "supervisor",
"timestamp": mocker.ANY,
+ "ti_id": ti_id,
}
]
