redoer update

Author: spompea-cfa

Dockerfile.redoer

@@ -7,7 +7,7 @@ RUN apt-get update \
  && apt-get -y autoremove \
  && apt-get -y clean
 
-RUN pip3 install --break-system-packages opentelemetry-distro opentelemetry-exporter-otlp-proto-http
+RUN pip3 install --break-system-packages opentelemetry-distro opentelemetry-exporter-otlp-proto-http psycopg2-binary
 # Above, `--break-system-packages` flag overrides the
 # "This environment is externally managed" error that calling pip
 # would otherwise incur here.

dev-scripts/check_export_tracker.py

@@ -46,3 +46,4 @@
 
 if len(sys.argv) == 2 and sys.argv[1] == 'dump':
     print(rslt)
+    print(f'Total: {len(rslt)}')

middleware/redoer.py

@@ -14,6 +14,7 @@
 from opentelemetry import metrics
 
 import util
+import db
 
 try:
     log.info('Importing senzing_core library . . .')
@@ -108,10 +109,12 @@ def _otel_queue_count_steward(tally):
                     have_rcd = 0
                     log.debug(SZ_TAG + 'Successfully redid one record via process_redo_record().')
 
-                    # TODO send affected entity IDs to tracker
+                    # Save affected entity IDs to tracker table for exporting later.
                     affected = util.parse_affected_entities_resp(resp)
+                    for entity_id in affected: db.add_entity_id(entity_id)
 
                     continue
+
                 except sz.SzRetryableError as sz_ret_err:
                     # We'll try to process this record again.
                     log.error(SZ_TAG + fmterr(sz_ret_err))