This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-8-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b441d8834fc99641196f1395118928be85dca68f Author: Narendra-Neerukonda <[email protected]> AuthorDate: Wed Feb 21 18:31:07 2024 +0530 fix: sort dag processing stats by last_runtime (#37302) * fix: sort dag processing stats by last_runtime * Update airflow/dag_processing/manager.py Co-authored-by: Andrey Anshin <[email protected]> --------- Co-authored-by: Jarek Potiuk <[email protected]> Co-authored-by: Andrey Anshin <[email protected]> (cherry picked from commit ac6a6373266cb84125cb16051cddf06845bfd4c2) --- airflow/dag_processing/manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/dag_processing/manager.py b/airflow/dag_processing/manager.py index b4b4ed65fe..39515e00a4 100644 --- a/airflow/dag_processing/manager.py +++ b/airflow/dag_processing/manager.py @@ -851,7 +851,7 @@ class DagFileProcessorManager(LoggingMixin): rows.append((file_path, processor_pid, runtime, num_dags, num_errors, last_runtime, last_run)) # Sort by longest last runtime. (Can't sort None values in python3) - rows.sort(key=lambda x: x[3] or 0.0) + rows.sort(key=lambda x: x[5] or 0.0, reverse=True) formatted_rows = [] for file_path, pid, runtime, num_dags, num_errors, last_runtime, last_run in rows:
