Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/writer.py
Show All 11 Lines | from swh.model.model import ( | ||||
OriginVisit, | OriginVisit, | ||||
OriginVisitStatus, | OriginVisitStatus, | ||||
Snapshot, | Snapshot, | ||||
Directory, | Directory, | ||||
Revision, | Revision, | ||||
Release, | Release, | ||||
Content, | Content, | ||||
SkippedContent, | SkippedContent, | ||||
RawExtrinsicMetadata, | |||||
MetadataFetcher, | |||||
MetadataAuthority, | |||||
) | ) | ||||
try: | try: | ||||
from swh.journal.writer import get_journal_writer | from swh.journal.writer import get_journal_writer | ||||
except ImportError: | except ImportError: | ||||
get_journal_writer = None # type: ignore | get_journal_writer = None # type: ignore | ||||
# mypy limitation, see https://github.com/python/mypy/issues/1153 | # mypy limitation, see https://github.com/python/mypy/issues/1153 | ||||
▲ Show 20 Lines • Show All 53 Lines • ▼ Show 20 Lines | class JournalWriter: | ||||
def origin_visit_status_add( | def origin_visit_status_add( | ||||
self, visit_statuses: Iterable[OriginVisitStatus] | self, visit_statuses: Iterable[OriginVisitStatus] | ||||
) -> None: | ) -> None: | ||||
self.write_additions("origin_visit_status", visit_statuses) | self.write_additions("origin_visit_status", visit_statuses) | ||||
def origin_add(self, origins: Iterable[Origin]) -> None: | def origin_add(self, origins: Iterable[Origin]) -> None: | ||||
self.write_additions("origin", origins) | self.write_additions("origin", origins) | ||||
def raw_extrinsic_metadata_add( | |||||
self, metadata: Iterable[RawExtrinsicMetadata] | |||||
) -> None: | |||||
self.write_additions("raw_extrinsic_metadata", metadata) | |||||
def metadata_fetcher_add(self, fetchers: Iterable[MetadataFetcher]) -> None: | |||||
self.write_additions("metadata_fetcher", fetchers) | |||||
def metadata_authority_add(self, authorities: Iterable[MetadataAuthority]) -> None: | |||||
self.write_additions("metadata_authority", authorities) |