Change extra connections loop logic

To be compatible with python3 and also airflow cli syntax
idealista · Jun 10, 2023 · f438b70 · f438b70
1 parent aad1580
commit f438b70
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/tasks/config.yml b/tasks/config.yml
@@ -121,8 +121,11 @@
 
 - name: Airflow | Add connections from configuration file
   command: "{{ airflow_executable }} connections add \
-  {% for key, value in item.iteritems() %}--{{ key }} '{{ value }}' \
-  {% endfor %}"
+      {% for key, value in item.items() %} \
+        {% if key == 'conn_id' %} {{value}} \
+        {% else %} --{{ key | replace('_', '-') }} '{{ value }}' \
+        {% endif %} \
+      {% endfor %}"
   become: true
   become_user: "{{ airflow_user }}"
   with_items: "{{ airflow_admin_connections }}"