From fd53c5af5b0739f7ba81bb7baa404784790964f5 Mon Sep 17 00:00:00 2001
From: Giambattista Bloisi <giambattista.bloisi@openaire.eu>
Date: Sun, 17 Mar 2024 21:32:40 +0100
Subject: [PATCH] simple test DAG

---
 airflow/dags/import_raw_graph.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/airflow/dags/import_raw_graph.py b/airflow/dags/import_raw_graph.py
index 1ac436e..9418bcd 100644
--- a/airflow/dags/import_raw_graph.py
+++ b/airflow/dags/import_raw_graph.py
@@ -86,10 +86,12 @@ def import_raw_graph():
                         "codec": "zstd_no_dict",
                         "replication.type": "SEGMENT",
 
-                        "translog.flush_threshold_size": "2048MB"
+                        "translog.flush_threshold_size": "2048MB",
+
+                        "mapping.ignore_malformed": "True"
                     }
 
-                },
+                }
                 # "mappings": mappings[entity]
             })