swh.indexer.journal_client module#

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

swh.indexer.journal_client.process_origin_visits(visits, scheduler, task_names)[source]#