Changeset View
Changeset View
Standalone View
Standalone View
swh/loader/core/loader.py
| Show First 20 Lines • Show All 405 Lines • ▼ Show 20 Lines | def eventful(self) -> bool: | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def store_data(self) -> None: | def store_data(self) -> None: | ||||
| assert self.origin | assert self.origin | ||||
| if self.config.get("save_data"): | if self.config.get("save_data"): | ||||
| self.save_data() | self.save_data() | ||||
| if self.has_contents(): | if self.has_contents(): | ||||
| contents = [] | |||||
| skipped_contents = [] | |||||
| for obj in self.get_contents(): | for obj in self.get_contents(): | ||||
| if isinstance(obj, Content): | if isinstance(obj, Content): | ||||
| contents.append(obj) | self.storage.content_add([obj]) | ||||
| elif isinstance(obj, SkippedContent): | elif isinstance(obj, SkippedContent): | ||||
| skipped_contents.append(obj) | self.storage.skipped_content_add([obj]) | ||||
| else: | else: | ||||
| raise TypeError(f"Unexpected content type: {obj}") | raise TypeError(f"Unexpected content type: {obj}") | ||||
| self.storage.skipped_content_add(skipped_contents) | |||||
| self.storage.content_add(contents) | |||||
| if self.has_directories(): | if self.has_directories(): | ||||
| self.storage.directory_add(list(self.get_directories())) | for directory in self.get_directories(): | ||||
| self.storage.directory_add([directory]) | |||||
| if self.has_revisions(): | if self.has_revisions(): | ||||
| self.storage.revision_add(list(self.get_revisions())) | for revision in self.get_revisions(): | ||||
| self.storage.revision_add([revision]) | |||||
| if self.has_releases(): | if self.has_releases(): | ||||
| self.storage.release_add(list(self.get_releases())) | for release in self.get_releases(): | ||||
| self.storage.release_add([release]) | |||||
| snapshot = self.get_snapshot() | snapshot = self.get_snapshot() | ||||
| self.storage.snapshot_add([snapshot]) | self.storage.snapshot_add([snapshot]) | ||||
| self.flush() | self.flush() | ||||
| self.loaded_snapshot_id = snapshot.id | self.loaded_snapshot_id = snapshot.id | ||||