feat: Check ES health before flushing handlers (#20)

edgarasg · web-flow · commit 919add88b2d6 · 2024-10-01T13:51:00.000+03:00
diff --git a/README.md b/README.md
@@ -60,7 +60,8 @@ You can now override the configuration files with your own versions by using the
 
 ## Dependency
 
-This role uses the json_query filter which [requires jmespath](https://github.com/ansible/ansible/issues/24319) on the local machine.
+- json_query filter requires [jmespath](https://github.com/ansible/ansible/issues/24319) on the local machine.
+- health check uses [python elasticsearch client](https://elasticsearch-py.readthedocs.io) which must be installed on the target machine.
 
 ## Testing
 
diff --git a/defaults/main.yml b/defaults/main.yml
@@ -70,3 +70,6 @@ es_ssl_verification_mode: "certificate"
 es_validate_certs: "yes"
 es_delete_unmanaged_file: true
 es_delete_unmanaged_native: true
+
+es_healthcheck_auth_scheme: https
+es_healthcheck_timeout: 3600
diff --git a/tasks/main.yml b/tasks/main.yml
@@ -59,6 +59,18 @@
   tags:
       - xpack
 
+- name: Wait for cluster status to become green
+  community.elastic.elastic_cluster_health:
+    auth_scheme: "{{ es_healthcheck_auth_scheme }}"
+    login_password: "{{ es_api_basic_auth_password }}"
+    login_user: "{{ es_api_basic_auth_username }}"
+    login_hosts: "{{ es_config['discovery.seed_hosts'] }}"
+    auth_method: http_auth
+    wait_for: status
+    to_be: green
+    timeout: "{{ es_healthcheck_timeout }}"
+  when: not es_bootstrap | default(false)
+
 - name: flush handlers
   meta: flush_handlers
 
