diff --git a/airflow/dags/import_skg_if.py b/airflow/dags/import_skg_if.py index 29be914..1922cb4 100644 --- a/airflow/dags/import_skg_if.py +++ b/airflow/dags/import_skg_if.py @@ -88,7 +88,9 @@ def skg_if_pipeline(): ) for entity in ENTITIES: - client.indices.delete(entity) + if client.indices.exists(entity): + client.indices.delete(entity) + client.indices.create(entity, { "settings": { "index": {