From 7e992a05072a90276d4cd361f264c39c90dc6f9f Mon Sep 17 00:00:00 2001 From: Ankita Katiyar <110245118+ankatiyar@users.noreply.github.com> Date: Tue, 5 Mar 2024 10:39:29 +0000 Subject: [PATCH] fix(airflow): Fix incorrect node names (#594) * Fix incorrect node names + switch e2e tests to spaceflights-pandas Signed-off-by: Ankita Katiyar * Not switch e2e tests starters for now Signed-off-by: Ankita Katiyar * Revert changes to e2e tests Signed-off-by: Ankita Katiyar --------- Signed-off-by: Ankita Katiyar Signed-off-by: tgoelles --- kedro-airflow/kedro_airflow/airflow_dag_template.j2 | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kedro-airflow/kedro_airflow/airflow_dag_template.j2 b/kedro-airflow/kedro_airflow/airflow_dag_template.j2 index d1d8b8237..796fbd2d5 100644 --- a/kedro-airflow/kedro_airflow/airflow_dag_template.j2 +++ b/kedro-airflow/kedro_airflow/airflow_dag_template.j2 @@ -65,7 +65,7 @@ with DAG( task_id="{{ node_name | safe | slugify }}", package_name=package_name, pipeline_name=pipeline_name, - node_name={% if node_list | length > 1 %}[{% endif %}{% for node in node_list %}"{{ node.name | safe | slugify }}"{% if not loop.last %}, {% endif %}{% endfor %}{% if node_list | length > 1 %}]{% endif %}, + node_name={% if node_list | length > 1 %}[{% endif %}{% for node in node_list %}"{{ node.name | safe }}"{% if not loop.last %}, {% endif %}{% endfor %}{% if node_list | length > 1 %}]{% endif %}, project_path=project_path, env=env, ),