Changeset View
Changeset View
Standalone View
Standalone View
swh/indexer/origin_head.py
Show All 30 Lines | ADDITIONAL_CONFIG = { | ||||
'tasks': ('dict', { | 'tasks': ('dict', { | ||||
'revision_metadata': 'revision_metadata', | 'revision_metadata': 'revision_metadata', | ||||
'origin_intrinsic_metadata': 'origin_metadata', | 'origin_intrinsic_metadata': 'origin_metadata', | ||||
}) | }) | ||||
} | } | ||||
CONFIG_BASE_FILENAME = 'indexer/origin_head' | CONFIG_BASE_FILENAME = 'indexer/origin_head' | ||||
def filter(self, ids): | |||||
yield from ids | |||||
def persist_index_computations(self, results, policy_update): | def persist_index_computations(self, results, policy_update): | ||||
"""Do nothing. The indexer's results are not persistent, they | """Do nothing. The indexer's results are not persistent, they | ||||
should only be piped to another indexer.""" | should only be piped to another indexer.""" | ||||
pass | pass | ||||
def next_step(self, results, task): | def next_step(self, results, task): | ||||
"""Once the head is found, call the RevisionMetadataIndexer | """Once the head is found, call the RevisionMetadataIndexer | ||||
on these revisions, then call the OriginMetadataIndexer with | on these revisions, then call the OriginMetadataIndexer with | ||||
▲ Show 20 Lines • Show All 172 Lines • Show Last 20 Lines |