Writes buffered table→count pairs as a JSON progress file (atomic via rename).
(self, load_id: str, table_counts: Dict[str, int])
| 690 | self.storage.create_folder(self.get_progress_dir(load_id), exists_ok=True) |
| 691 | |
| 692 | def write_progress(self, load_id: str, table_counts: Dict[str, int]) -> None: |
| 693 | """Writes buffered table→count pairs as a JSON progress file (atomic via rename).""" |
| 694 | if not table_counts: |
| 695 | return |
| 696 | progress_dir = self.get_progress_dir(load_id) |
| 697 | file_path = os.path.join(progress_dir, uniq_id() + ".progress.json") |
| 698 | self.storage.save(file_path, json.dumps(table_counts)) |
| 699 | |
| 700 | def collect_progress(self, load_id: str) -> Dict[str, int]: |
| 701 | """Reads and deletes all progress files, returning aggregated table→items_count.""" |