1 {%- from "elasticsearch/map.jinja" import client with context %}
2 {%- if client.get('enabled', False) %}
5 - elasticsearch.client.service
7 {%- for index_name, index in client.get('index', {}).iteritems() %}
8 # TODO: "Replace with module.run when bug is fixed".
9 # Since bug in retry logic in salt (#49895) we need to use a workaround for now.
10 elasticsearch_check_cluster_status_before_index_template_upgrade_{{ index_name }}:
12 - name: curl -sfk {{ client.server.get("scheme", "http") }}://{{ client.server.host }}:{{ client.server.port }}/_cat/health | awk '{print $4}' | grep green
19 elasticsearch_index_template_upgrade_{{ index_name }}:
21 {%- if index.get('enabled', False) %}
23 {%- if index.definition is defined %}
24 {% set definition = index.definition %}
26 {%- if index.template is defined %}
27 {%- import_json index.template as definition %}
30 {%- if definition is defined %}
32 - name: elasticsearch.index_template_create
33 - m_name: {{ index_name }}
34 - body: '{{ definition|json }}'
36 - pkg: elasticsearch_client_packages