swh.storage.replay module

swh.storage.replay.process_replay_objects(all_objects, *, storage)[source]
swh.storage.replay.collision_aware_content_add(content_add_fn: Callable[[Iterable[Any]], None], contents: List[swh.model.model.BaseContent]) → None[source]
Add contents to storage. If a hash collision is detected, an error is

logged. Then this adds the other non colliding contents to the storage.

Parameters
  • content_add_fn – Storage content callable

  • contents – List of contents or skipped contents to add to storage