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 | |||||