@@ -21,10 +21,10 @@ def _validate_document(document: str):
2121 result = validator .validate (data = docref )
2222
2323 if not result .is_valid :
24- raise Exception ("Failed to validate document: " + str (result .issues ))
24+ raise RuntimeError ("Failed to validate document: " + str (result .issues ))
2525
2626
27- def _find_invalid_pointers (table_name : str ) -> dict [str , float ]:
27+ def _find_invalid_pointers (table_name : str ) -> dict [str , float | int ]:
2828 """
2929 Find pointers in the given table that are invalid.
3030 Parameters:
@@ -45,12 +45,12 @@ def _find_invalid_pointers(table_name: str) -> dict[str, float]:
4545
4646 for page in paginator .paginate (** params ):
4747 for item in page ["Items" ]:
48- id = item .get ("id" , {}).get ("S" )
48+ pointer_id = item .get ("id" , {}).get ("S" )
4949 document = item .get ("document" , {}).get ("S" , "" )
5050 try :
5151 _validate_document (document )
5252 except Exception as exc :
53- invalid_pointers .append ((id , exc ))
53+ invalid_pointers .append ((pointer_id , exc ))
5454
5555 total_scanned_count += page ["ScannedCount" ]
5656
@@ -64,12 +64,13 @@ def _find_invalid_pointers(table_name: str) -> dict[str, float]:
6464
6565 end_time = datetime .now (tz = timezone .utc )
6666
67+ print (" Done" ) # noqa
68+
6769 print ("Writing invalid_pointers to file ./invalid_pointers.txt ..." ) # noqa
6870 with open ("invalid_pointers.txt" , "w" ) as f :
69- for id , err in invalid_pointers :
70- f .write (f"{ id } : { err } \n " )
71+ for _id , err in invalid_pointers :
72+ f .write (f"{ _id } : { err } \n " )
7173
72- print (" Done" ) # noqa
7374 return {
7475 "invalid_pointers" : len (invalid_pointers ),
7576 "scanned_count" : total_scanned_count ,
0 commit comments