Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/cassandra/storage.py
| Show First 20 Lines • Show All 1,387 Lines • ▼ Show 20 Lines | ) -> List[RawExtrinsicMetadata]: | ||||
| raise Exception( | raise Exception( | ||||
| "Found multiple RawExtrinsicMetadata objects with the same id: " | "Found multiple RawExtrinsicMetadata objects with the same id: " | ||||
| + hash_to_hex(key.id) | + hash_to_hex(key.id) | ||||
| ) | ) | ||||
| results.update(map(converters.row_to_raw_extrinsic_metadata, candidates)) | results.update(map(converters.row_to_raw_extrinsic_metadata, candidates)) | ||||
| return list(results) | return list(results) | ||||
| def raw_extrinsic_metadata_get_authorities( | |||||
| self, target: ExtendedSWHID | |||||
| ) -> List[MetadataAuthority]: | |||||
| return [ | |||||
| MetadataAuthority( | |||||
| type=MetadataAuthorityType(authority_type), url=authority_url | |||||
| ) | |||||
| for (authority_type, authority_url) in set( | |||||
| self._cql_runner.raw_extrinsic_metadata_get_authorities(str(target)) | |||||
| ) | |||||
| ] | |||||
| def metadata_fetcher_add(self, fetchers: List[MetadataFetcher]) -> Dict[str, int]: | def metadata_fetcher_add(self, fetchers: List[MetadataFetcher]) -> Dict[str, int]: | ||||
| self.journal_writer.metadata_fetcher_add(fetchers) | self.journal_writer.metadata_fetcher_add(fetchers) | ||||
| for fetcher in fetchers: | for fetcher in fetchers: | ||||
| self._cql_runner.metadata_fetcher_add( | self._cql_runner.metadata_fetcher_add( | ||||
| MetadataFetcherRow(name=fetcher.name, version=fetcher.version,) | MetadataFetcherRow(name=fetcher.name, version=fetcher.version,) | ||||
| ) | ) | ||||
| return {"metadata_fetcher:add": len(fetchers)} | return {"metadata_fetcher:add": len(fetchers)} | ||||
| ▲ Show 20 Lines • Show All 110 Lines • Show Last 20 Lines | |||||