Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/storage/archive.py
| from typing import Any, Dict, List | from typing import Any, Dict, Iterable, List | ||||
| # from functools import lru_cache | # from functools import lru_cache | ||||
| from methodtools import lru_cache | from methodtools import lru_cache | ||||
| from swh.storage.interface import StorageInterface | from swh.storage.interface import StorageInterface | ||||
| class ArchiveStorage: | class ArchiveStorage: | ||||
| Show All 17 Lines | def iter_origin_visits(self, origin: str): | ||||
| yield from iter_origin_visits(self.storage, origin) | yield from iter_origin_visits(self.storage, origin) | ||||
| def iter_origin_visit_statuses(self, origin: str, visit: int): | def iter_origin_visit_statuses(self, origin: str, visit: int): | ||||
| from swh.storage.algos.origin import iter_origin_visit_statuses | from swh.storage.algos.origin import iter_origin_visit_statuses | ||||
| # TODO: filter unused fields | # TODO: filter unused fields | ||||
| yield from iter_origin_visit_statuses(self.storage, origin, visit) | yield from iter_origin_visit_statuses(self.storage, origin, visit) | ||||
| def release_get(self, ids: List[bytes]): | def release_get(self, ids: Iterable[bytes]): | ||||
| # TODO: filter unused fields | # TODO: filter unused fields | ||||
| yield from self.storage.release_get(ids) | yield from self.storage.release_get(list(ids)) | ||||
| def revision_get(self, ids: List[bytes]): | def revision_get(self, ids: Iterable[bytes]): | ||||
| # TODO: filter unused fields | # TODO: filter unused fields | ||||
| yield from self.storage.revision_get(ids) | yield from self.storage.revision_get(list(ids)) | ||||
| def snapshot_get_all_branches(self, snapshot: bytes): | def snapshot_get_all_branches(self, snapshot: bytes): | ||||
| from swh.storage.algos.snapshot import snapshot_get_all_branches | from swh.storage.algos.snapshot import snapshot_get_all_branches | ||||
| # TODO: filter unused fields | # TODO: filter unused fields | ||||
| return snapshot_get_all_branches(self.storage, snapshot) | return snapshot_get_all_branches(self.storage, snapshot) | ||||