保存处理进度
(self, current_file: str = None, total_files: int = 0, processed_count: int = 0)
| 489 | ] |
| 490 | |
| 491 | def save_progress(self, current_file: str = None, total_files: int = 0, processed_count: int = 0): |
| 492 | """保存处理进度""" |
| 493 | progress_data = { |
| 494 | "processed_files": list(self.processed_files), |
| 495 | "current_file": current_file, |
| 496 | "total_files": total_files, |
| 497 | "processed_count": processed_count, |
| 498 | "current_batch": self.current_batch, |
| 499 | "concept_id_counter": self.concept_id_counter, |
| 500 | "timestamp": datetime.now().isoformat(), |
| 501 | "concepts_count": len(self.concepts), |
| 502 | "relationships_count": len(self.relationships) |
| 503 | } |
| 504 | |
| 505 | with open(self.progress_file, 'w', encoding='utf-8') as f: |
| 506 | json.dump(progress_data, f, ensure_ascii=False, indent=2) |
| 507 | |
| 508 | def load_progress(self) -> Dict: |
| 509 | """加载处理进度""" |
no outgoing calls
no test coverage detected