simple test DAG

2024-03-18 12:15:28 +01:00 · 2024-03-18 12:15:28 +01:00 · 5502f449a5
parent cbdb6f3640
commit 5502f449a5
1 changed files with 3 additions and 1 deletions
--- 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": {