This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-8-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 0e60195448d6a8b0dca6a72e279b1e41efe37c35 Author: Brent Bovenzi <[email protected]> AuthorDate: Wed Mar 13 09:46:07 2024 -0400 Fix task instances list link (#38096) (cherry picked from commit 43d7f6d3da0192c3abd07c9f0dab54e6da605621) --- 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 16d0950989..389d9e25ca 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( """ <span style="white-space: nowrap;"> <a href="{url}">{task_id}</a> - <a href="{url_root}" title="Filter on this task and upstream"> + <a href="{url_root}" title="Filter on this task"> <span class="material-icons" style="margin-left:0;" aria-hidden="true">filter_alt</span> </a>
