From ccc607ce0c8fc65d31d805e422abc5623bc74c43 Mon Sep 17 00:00:00 2001 From: vladd-bit Date: Tue, 20 Feb 2024 11:20:11 +0000 Subject: [PATCH] NiFi: updated ann_manager script. --- nifi/user-scripts/annotation_manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi/user-scripts/annotation_manager.py b/nifi/user-scripts/annotation_manager.py index 585294e8..2d4a12bc 100644 --- a/nifi/user-scripts/annotation_manager.py +++ b/nifi/user-scripts/annotation_manager.py @@ -80,7 +80,7 @@ def main(): output_stream["content"].append(record) elif OPERATION_MODE == "insert": - query = "INSERT INTO annotations (elasticsearch_id) VALUES (" + '"' + str(record["meta.docid"]) + "_" + str(record["nlp.id"]) + '"' + ")" + query = "INSERT INTO annotations (elasticsearch_id) VALUES (" + '"' + str(record["meta." + DOCUMENT_ID_FIELD_NAME]) + "_" + str(record["nlp.id"]) + '"' + ")" result = connect_and_query(query, db_file_path, sql_script_mode=True) if len(result) == 0: