This is an automated email from the ASF dual-hosted git repository.
amoghrajesh 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 30902929d3a Fix misleading log message in task_runner clear_on_success
block (#67836)
30902929d3a is described below
commit 30902929d3adf2c2b189cdbd086f2084da3419fa
Author: Amogh Desai <[email protected]>
AuthorDate: Mon Jun 1 18:24:41 2026 +0530
Fix misleading log message in task_runner clear_on_success block (#67836)
---
task-sdk/src/airflow/sdk/execution_time/task_runner.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
index df340f25112..9f2599a1963 100644
--- a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
+++ b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
@@ -1543,8 +1543,9 @@ def _handle_current_task_success(
outlet_events = list(_serialize_outlet_events(context["outlet_events"]))
if conf.getboolean("state_store", "clear_on_success"):
- log.info("Task state will be cleared by the server because
clear_on_success is enabled.")
-
+ log.info(
+ "Clearing task state from custom backend as clear_on_success is
enabled. The database references will be cleared by the API server."
+ )
context["task_state"]._clear_backend_only()
msg = SucceedTask(
