simple test DAG

2024-03-17 18:10:49 +01:00 · 2024-03-17 18:10:49 +01:00 · a7a6f8e95f
parent df6cd00621
commit a7a6f8e95f
1 changed files with 1 additions and 1 deletions
--- a/airflow/dags/import_raw_graph.py
+++ b/airflow/dags/import_raw_graph.py
@ -129,7 +129,7 @@ def import_raw_graph():
                    for line in buff:
                        data = json.loads(line)
                        data['_index'] = entity
-                        data['_id'] = data['local_identifier']
+                        data['_id'] = data['id']
                        yield data

        succeeded = 0