Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/in_memory.py
| Show First 20 Lines • Show All 654 Lines • ▼ Show 20 Lines | class InMemoryCqlRunner: | ||||
| ) -> Iterable[RawExtrinsicMetadataRow]: | ) -> Iterable[RawExtrinsicMetadataRow]: | ||||
| metadata = self._raw_extrinsic_metadata.get_from_partition_key((target,)) | metadata = self._raw_extrinsic_metadata.get_from_partition_key((target,)) | ||||
| return ( | return ( | ||||
| m | m | ||||
| for m in metadata | for m in metadata | ||||
| if m.authority_type == authority_type and m.authority_url == authority_url | if m.authority_type == authority_type and m.authority_url == authority_url | ||||
| ) | ) | ||||
| def raw_extrinsic_metadata_get_authorities( | |||||
| self, target: str | |||||
| ) -> Iterable[Tuple[str, str]]: | |||||
| metadata = self._raw_extrinsic_metadata.get_from_partition_key((target,)) | |||||
| return ((m.authority_type, m.authority_url) for m in metadata) | |||||
| ######################### | ######################### | ||||
| # 'extid' table | # 'extid' table | ||||
| ######################### | ######################### | ||||
| def _extid_add_finalize(self, extid: ExtIDRow) -> None: | def _extid_add_finalize(self, extid: ExtIDRow) -> None: | ||||
| self._extid.insert(extid) | self._extid.insert(extid) | ||||
| self.increment_counter("extid", 1) | self.increment_counter("extid", 1) | ||||
| def extid_add_prepare(self, extid: ExtIDRow): | def extid_add_prepare(self, extid: ExtIDRow): | ||||
| ▲ Show 20 Lines • Show All 50 Lines • Show Last 20 Lines | |||||