swh.search.journal_client module#

swh.search.journal_client.fetch_last_revision_release_date(snapshot_id: bytes, storage: StorageInterface) → Dict[str, str][source]#

swh.search.journal_client.process_journal_objects(messages, *, search, storage=None)[source]#: Worker function for JournalClient.process(worker_fn), after currification of scheduler and task_names.

swh.search.journal_client.process_origins(origins, search)[source]#

swh.search.journal_client.process_origin_visit_statuses(visit_statuses, search, storage)[source]#

swh.search.journal_client.process_origin_intrinsic_metadata(origin_metadata, search)[source]#

swh.search.journal_client.process_origin_extrinsic_metadata(origin_metadata, search)[source]#