Skip to content

Commit

Permalink
Update G2Loader.py
Browse files Browse the repository at this point in the history
  • Loading branch information
antaenc authored Mar 8, 2024
1 parent 376e7fe commit 6781dc3
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions G2Loader.py
Original file line number Diff line number Diff line change
Expand Up @@ -922,7 +922,7 @@ def g2thread_error(msg, action):

# Record is JSON
data_source = row.get('DATA_SOURCE', '')
record_id = str(row.get('RECORD_ID', ''))
record_id = str(row.get('RECORD_ID', ''))

# Is the record from the work queue specifically a redo record to be processed during redo time/mode?
if is_redo_record:
Expand Down Expand Up @@ -1751,7 +1751,8 @@ def governor_setup():
* applications, process and systems. G2Loader is a demonstrable application using some of the ingestion APIs. *
* *
* Typically, the Senzing APIs are embedded in and called by streaming systems to provide real time entity *
* resolution capabilities. Example of a streaming ingest utility: https://github.com/Senzing/stream-loader *
* resolution capabilities. Example of a streaming ingest utility: https://github.com/senzing-garage/stream- *
* loader *
* *
***************************************************************************************************************
'''))
Expand All @@ -1772,8 +1773,8 @@ def governor_setup():
For appropriate ingestion infrastructure please check:
https://github.com/Senzing/stream-producer
https://github.com/Senzing/stream-loader
https://github.com/senzing/stream-producer
https://github.com/senzing/stream-loader
*****************************
'''))
Expand Down

0 comments on commit 6781dc3

Please sign in to comment.