simple test DAG

2024-03-17 21:32:40 +01:00 · 2024-03-17 21:32:40 +01:00 · fd53c5af5b
parent fd25f9bf59
commit fd53c5af5b
1 changed files with 4 additions and 2 deletions
--- 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]
            })