NiFi scripts: updated ann bulk parse script.

CogStack · Dec 19, 2024 · 1f69f38 · 1f69f38
1 parent 1d53cb0
commit 1f69f38
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py b/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py
@@ -71,7 +71,7 @@ def process(self, inputStream, outputStream):
                     log.debug("Document id :" + str(record[DOCUMENT_ID_FIELD_NAME]) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.")
             except KeyError:
                 invalid_record_ids.append(record)
-                log.debug(str(record) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.")
+                log.debug(str(record["_id"]) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.")
 
         outputStream.write(json.dumps({"content": out_records}).encode("UTF-8"))