Changeset View

Standalone View

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