Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/storage.py
Show First 20 Lines • Show All 1,424 Lines • ▼ Show 20 Lines | ) -> PagedResult[RawExtrinsicMetadata]: | ||||
) | ) | ||||
) | ) | ||||
).decode() | ).decode() | ||||
else: | else: | ||||
next_page_token = None | next_page_token = None | ||||
return PagedResult(next_page_token=next_page_token, results=results,) | return PagedResult(next_page_token=next_page_token, results=results,) | ||||
@db_transaction() | |||||
def raw_extrinsic_metadata_get_by_ids( | |||||
self, ids: List[Sha1Git], db=None, cur=None, | |||||
) -> List[RawExtrinsicMetadata]: | |||||
return [ | |||||
converters.db_to_raw_extrinsic_metadata( | |||||
dict(zip(db.raw_extrinsic_metadata_get_cols, row)) | |||||
) | |||||
for row in db.raw_extrinsic_metadata_get_by_ids(ids) | |||||
] | |||||
@timed | @timed | ||||
@process_metrics | @process_metrics | ||||
@db_transaction() | @db_transaction() | ||||
def metadata_fetcher_add( | def metadata_fetcher_add( | ||||
self, fetchers: List[MetadataFetcher], db=None, cur=None | self, fetchers: List[MetadataFetcher], db=None, cur=None | ||||
) -> Dict[str, int]: | ) -> Dict[str, int]: | ||||
fetchers = list(fetchers) | fetchers = list(fetchers) | ||||
self.journal_writer.metadata_fetcher_add(fetchers) | self.journal_writer.metadata_fetcher_add(fetchers) | ||||
▲ Show 20 Lines • Show All 62 Lines • Show Last 20 Lines |