From 7f21928c8ef6fa9542f64efc084f5458cea0b4b9 Mon Sep 17 00:00:00 2001 From: Brent Bovenzi Date: Tue, 12 Mar 2024 16:45:00 -0700 Subject: [PATCH] Fix task instances list link --- airflow/www/utils.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/airflow/www/utils.py b/airflow/www/utils.py index 0880303ed89c4..379e5a050279f 100644 --- a/airflow/www/utils.py +++ b/airflow/www/utils.py @@ -422,6 +422,7 @@ def task_instance_link(attr): """Generate a URL to the Graph view for a TaskInstance.""" dag_id = attr.get("dag_id") task_id = attr.get("task_id") + run_id = attr.get("run_id") execution_date = attr.get("dag_run.execution_date") or attr.get("execution_date") or timezone.utcnow() url = url_for( "Airflow.task", @@ -431,13 +432,18 @@ def task_instance_link(attr): map_index=attr.get("map_index", -1), ) url_root = url_for( - "Airflow.graph", dag_id=dag_id, root=task_id, execution_date=execution_date.isoformat() + "Airflow.grid", + dag_id=dag_id, + task_id=task_id, + dag_run_id=run_id, + tab="graph", + map_index=attr.get("map_index", -1), ) return Markup( """ {task_id} - +