Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/storage.py
| Show First 20 Lines • Show All 1,250 Lines • ▼ Show 20 Lines | ) -> None: | ||||
| metadata = list(metadata) | metadata = list(metadata) | ||||
| self.journal_writer.raw_extrinsic_metadata_add(metadata) | self.journal_writer.raw_extrinsic_metadata_add(metadata) | ||||
| counter = Counter[MetadataTargetType]() | counter = Counter[MetadataTargetType]() | ||||
| for metadata_entry in metadata: | for metadata_entry in metadata: | ||||
| authority_id = self._get_authority_id(metadata_entry.authority, db, cur) | authority_id = self._get_authority_id(metadata_entry.authority, db, cur) | ||||
| fetcher_id = self._get_fetcher_id(metadata_entry.fetcher, db, cur) | fetcher_id = self._get_fetcher_id(metadata_entry.fetcher, db, cur) | ||||
| db.raw_extrinsic_metadata_add( | db.raw_extrinsic_metadata_add( | ||||
| id=metadata_entry.id, | |||||
| type=metadata_entry.type.value, | type=metadata_entry.type.value, | ||||
| target=str(metadata_entry.target), | target=str(metadata_entry.target), | ||||
| discovery_date=metadata_entry.discovery_date, | discovery_date=metadata_entry.discovery_date, | ||||
| authority_id=authority_id, | authority_id=authority_id, | ||||
| fetcher_id=fetcher_id, | fetcher_id=fetcher_id, | ||||
| format=metadata_entry.format, | format=metadata_entry.format, | ||||
| metadata=metadata_entry.metadata, | metadata=metadata_entry.metadata, | ||||
| origin=metadata_entry.origin, | origin=metadata_entry.origin, | ||||
| ▲ Show 20 Lines • Show All 165 Lines • Show Last 20 Lines | |||||