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 | |||||