This is an automated email from the ASF dual-hosted git repository.
uranusjr 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 c9b21b8026 Faster grid view (#23951)
c9b21b8026 is described below
commit c9b21b8026c595878ee4cc934209fc1fc2ca2396
Author: Jed Cunningham <[email protected]>
AuthorDate: Thu May 26 22:00:09 2022 -0600
Faster grid view (#23951)
---
airflow/www/utils.py | 16 ++++++++++++----
1 file changed, 12 insertions(+), 4 deletions(-)
diff --git a/airflow/www/utils.py b/airflow/www/utils.py
index 0a7de05abf..48512f03fa 100644
--- a/airflow/www/utils.py
+++ b/airflow/www/utils.py
@@ -129,7 +129,15 @@ def get_mapped_summary(parent_instance, task_instances):
def get_task_summaries(task, dag_runs: List[DagRun], session: Session) ->
List[Dict[str, Any]]:
- tis = session.query(TaskInstance).filter(
+ tis = session.query(
+ TaskInstance.task_id,
+ TaskInstance.run_id,
+ TaskInstance.map_index,
+ TaskInstance.state,
+ TaskInstance.start_date,
+ TaskInstance.end_date,
+ TaskInstance._try_number,
+ ).filter(
TaskInstance.dag_id == task.dag_id,
TaskInstance.run_id.in_([dag_run.run_id for dag_run in dag_runs]),
TaskInstance.task_id == task.task_id,
@@ -144,9 +152,9 @@ def get_task_summaries(task, dag_runs: List[DagRun],
session: Session) -> List[D
)
try_count = (
- task_instance.prev_attempted_tries
- if task_instance.prev_attempted_tries != 0
- else task_instance.try_number
+ task_instance._try_number
+ if task_instance._try_number != 0 or task_instance.state in
State.running
+ else task_instance._try_number + 1
)
return {
