Changeset View
Changeset View
Standalone View
Standalone View
swh/indexer/metadata.py
Show First 20 Lines • Show All 307 Lines • ▼ Show 20 Lines | def index(self, origin, *, origin_head_map): | ||||
for item in revision_metadata: | for item in revision_metadata: | ||||
assert item['id'] == revision_id | assert item['id'] == revision_id | ||||
# Get the metadata of that revision, and return it | # Get the metadata of that revision, and return it | ||||
results.append({ | results.append({ | ||||
'origin_id': origin['id'], | 'origin_id': origin['id'], | ||||
'metadata': item['translated_metadata'], | 'metadata': item['translated_metadata'], | ||||
'from_revision': revision_id, | 'from_revision': revision_id, | ||||
'indexer_configuration_id': | 'indexer_configuration_id': | ||||
item['indexer_configuration_id'], | item['tool']['id'], | ||||
}) | }) | ||||
return results | return results | ||||
def persist_index_computations(self, results, policy_update): | def persist_index_computations(self, results, policy_update): | ||||
self.idx_storage.origin_intrinsic_metadata_add( | self.idx_storage.origin_intrinsic_metadata_add( | ||||
list(itertools.chain(*results)), | list(itertools.chain(*results)), | ||||
conflict_update=(policy_update == 'update-dups')) | conflict_update=(policy_update == 'update-dups')) | ||||
Show All 13 Lines |