probe

Author: antaenc

CHANGELOG.md

@@ -7,6 +7,12 @@ This project adheres to [Semantic Versioning].
 
 ## [Unreleased]
 
+## [0.0.39] - 2026-04-20
+
+### Fixed in 0.0.39
+
+- Long running record check in `sz_file_loader` could error on long running redo records
+
 ## [0.0.38] - 2026-04-16
 
 ### Added in 0.0.38

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "sz-python-tools"
-version = "0.0.38"
+version = "0.0.39"
 description = "Senzing Python Tools"
 authors = [{ name = "senzing", email = "support@senzing.com" }]
 readme = "README.md"

sz_tools/sz_file_loader

@@ -776,12 +776,21 @@ def long_running_check(
             if duration > LONG_RECORD:
                 num_stuck += 1
                 stuck_record = _json_loads(payload[0])
-                logger.warning(
-                    "Long running record (%s): %s - %s",
+                stuck_data_source = stuck_record.get("DATA_SOURCE")
+                stuck_record_id = stuck_record.get("RECORD_ID")
+                if not stuck_data_source or not stuck_record_id:
+                    logger.warning(
+                    "Long running record (%s): %s",
                     f"{duration / 60:.3g}",
-                    f"{stuck_record['DATA_SOURCE']}",
-                    f"{stuck_record['RECORD_ID']}",
-                )
+                    stuck_record,
+                    )
+                else:
+                    logger.warning(
+                        "Long running record (%s): %s - %s",
+                        f"{duration / 60:.3g}",
+                        stuck_data_source,
+                        stuck_record_id
+                    )
 
     if num_stuck >= num_workers:
         logger.warning("All %s threads are stuck processing long running records", num_workers)