simple test DAG

2024-03-18 10:14:59 +01:00 · 2024-03-18 10:14:59 +01:00 · bf939c0254
parent fa3214dc2c
commit bf939c0254
1 changed files with 2 additions and 1 deletions
--- a/airflow/dags/import_eosc_catalog.py
+++ b/airflow/dags/import_eosc_catalog.py
@ -88,7 +88,8 @@ def eosc_catalog_import():
        )

        for entity in ENTITIES:
-            client.indices.delete(entity)
+            if client.indices.existsentity:
+                client.indices.delete(entity)
            client.indices.create(entity, {
                "settings": {
                    "index": {