files: report checksum fails

Author: kpsherva

cds_migrator_kit/rdm/records/load/load.py

@@ -115,7 +115,18 @@ def _load_files(self, draft, entry, version_files):
                 )
                 legacy_checksum = f"md5:{file_data['checksum']}"
                 new_checksum = result.to_dict()["checksum"]
-                assert legacy_checksum == new_checksum
+                try:
+                    assert legacy_checksum == new_checksum
+                except AssertionError:
+                    raise ManualImportRequired(
+                        message=f"Files checksum failed legacy:{legacy_checksum} calculated new: {new_checksum}",
+                        field="checksum",
+                        stage="load",
+                        recid=recid,
+                        priority="critical",
+                        value=file_data["key"],
+                        subfield=None,
+                    )
 
             except Exception as e:
                 exc = ManualImportRequired(
@@ -270,6 +281,7 @@ def _pre_publish(self, identity, entry, version, draft):
 
         self._load_record_access(draft, access)
         self._load_files(draft, entry, files)
+
         return draft
 
     def _load_versions(self, entry, logger):