From a7a6f8e95f68ce8db27eb9c68cf431a7c1fa93d1 Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Sun, 17 Mar 2024 18:10:49 +0100 Subject: [PATCH] simple test DAG --- airflow/dags/import_raw_graph.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/dags/import_raw_graph.py b/airflow/dags/import_raw_graph.py index 6a9592f..d115fba 100644 --- 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