swh.indexer.storage.writer module

class swh.indexer.storage.writer.JournalWriter(tool_getter: Callable[[int], Dict[str, Any]], journal_writer)

Bases: object

Journal writer storage collaborator. It’s in charge of adding objects to the journal.

write_additions(obj_type, entries: Iterable[swh.indexer.storage.model.BaseRow]) → None