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 cfd6ca6 Add new map_index field to log message (#22098)
cfd6ca6 is described below
commit cfd6ca6d425e26288bc5d8db59fd886896e9885c
Author: Steve Zhang <[email protected]>
AuthorDate: Tue Mar 8 14:50:14 2022 -0800
Add new map_index field to log message (#22098)
---
airflow/jobs/scheduler_job.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
index 4bbb0a4..d3bebc2 100644
--- a/airflow/jobs/scheduler_job.py
+++ b/airflow/jobs/scheduler_job.py
@@ -588,7 +588,7 @@ class SchedulerJob(BaseJob):
continue
msg = (
- "TaskInstance Finished: dag_id=%s, task_id=%s, run_id=%s, "
+ "TaskInstance Finished: dag_id=%s, task_id=%s, run_id=%s,
map_index=%s, "
"run_start_date=%s, run_end_date=%s, "
"run_duration=%s, state=%s, executor_state=%s, try_number=%s,
max_tries=%s, job_id=%s, "
"pool=%s, queue=%s, priority_weight=%d, operator=%s"
@@ -598,6 +598,7 @@ class SchedulerJob(BaseJob):
ti.dag_id,
ti.task_id,
ti.run_id,
+ ti.map_index,
ti.start_date,
ti.end_date,
ti.duration,
