This is an automated email from the ASF dual-hosted git repository.
ferruzzi 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 7152b2a7f2e Improve the log file template for ExecuteCallback by
including dag_id and run_id in the path (#62616)
7152b2a7f2e is described below
commit 7152b2a7f2e08ba3c477d3fc3632dc82976db78c
Author: Henry Chen <[email protected]>
AuthorDate: Wed Mar 11 03:59:44 2026 +0800
Improve the log file template for ExecuteCallback by including dag_id and
run_id in the path (#62616)
---
airflow-core/src/airflow/executors/workloads/callback.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/executors/workloads/callback.py
b/airflow-core/src/airflow/executors/workloads/callback.py
index 2563f9a78f5..273c5595367 100644
--- a/airflow-core/src/airflow/executors/workloads/callback.py
+++ b/airflow-core/src/airflow/executors/workloads/callback.py
@@ -90,7 +90,7 @@ class ExecuteCallback(BaseDagBundleWorkload):
name=dag_run.dag_model.bundle_name,
version=dag_run.bundle_version,
)
- fname = f"executor_callbacks/{callback.id}" # TODO: better log file
template
+ fname =
f"executor_callbacks/{dag_run.dag_id}/{dag_run.run_id}/{callback.id}"
return cls(
callback=CallbackDTO.model_validate(callback,
from_attributes=True),
