diff --git a/airflow/dags/init_opensearch_templates.py b/airflow/dags/init_opensearch_templates.py index b8d9d35..31f559b 100644 --- a/airflow/dags/init_opensearch_templates.py +++ b/airflow/dags/init_opensearch_templates.py @@ -1004,6 +1004,7 @@ def init_opensearch(os_client: OpenSearch): # try: # os_client.indices.get_index_template("interoperability") # except NotFoundError: + os_client.indices.delete_index_template(name="interoperability") os_client.indices.put_index_template( name="interoperability", body={