Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/cassandra/storage.py
| Show First 20 Lines • Show All 1,061 Lines • ▼ Show 20 Lines | def raw_extrinsic_metadata_add(self, metadata: List[RawExtrinsicMetadata]) -> None: | ||||
| path=metadata_entry.path, | path=metadata_entry.path, | ||||
| directory=map_optional(str, metadata_entry.directory), | directory=map_optional(str, metadata_entry.directory), | ||||
| ) | ) | ||||
| except TypeError as e: | except TypeError as e: | ||||
| raise StorageArgumentException(*e.args) | raise StorageArgumentException(*e.args) | ||||
| def raw_extrinsic_metadata_get( | def raw_extrinsic_metadata_get( | ||||
| self, | self, | ||||
| object_type: MetadataTargetType, | type: MetadataTargetType, | ||||
| id: Union[str, SWHID], | id: Union[str, SWHID], | ||||
| authority: MetadataAuthority, | authority: MetadataAuthority, | ||||
| after: Optional[datetime.datetime] = None, | after: Optional[datetime.datetime] = None, | ||||
| page_token: Optional[bytes] = None, | page_token: Optional[bytes] = None, | ||||
| limit: int = 1000, | limit: int = 1000, | ||||
| ) -> PagedResult[RawExtrinsicMetadata]: | ) -> PagedResult[RawExtrinsicMetadata]: | ||||
| if object_type == MetadataTargetType.ORIGIN: | if type == MetadataTargetType.ORIGIN: | ||||
| if isinstance(id, SWHID): | if isinstance(id, SWHID): | ||||
| raise StorageArgumentException( | raise StorageArgumentException( | ||||
| f"raw_extrinsic_metadata_get called with object_type='origin', " | f"raw_extrinsic_metadata_get called with type='origin', " | ||||
| f"but provided id is an SWHID: {id!r}" | f"but provided id is an SWHID: {id!r}" | ||||
| ) | ) | ||||
| else: | else: | ||||
| if not isinstance(id, SWHID): | if not isinstance(id, SWHID): | ||||
| raise StorageArgumentException( | raise StorageArgumentException( | ||||
| f"raw_extrinsic_metadata_get called with object_type!='origin', " | f"raw_extrinsic_metadata_get called with type!='origin', " | ||||
| f"but provided id is not an SWHID: {id!r}" | f"but provided id is not an SWHID: {id!r}" | ||||
| ) | ) | ||||
| if page_token is not None: | if page_token is not None: | ||||
| (after_date, after_fetcher_name, after_fetcher_url) = msgpack_loads( | (after_date, after_fetcher_name, after_fetcher_url) = msgpack_loads( | ||||
| base64.b64decode(page_token) | base64.b64decode(page_token) | ||||
| ) | ) | ||||
| if after and after_date < after: | if after and after_date < after: | ||||
| ▲ Show 20 Lines • Show All 123 Lines • Show Last 20 Lines | |||||