Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/replay.py
Show First 20 Lines • Show All 130 Lines • ▼ Show 20 Lines | elif object_type in ("origin_visit", "origin_visit_status"): | ||||
for obj in objects: | for obj in objects: | ||||
origins.append(Origin(url=obj["origin"])) | origins.append(Origin(url=obj["origin"])) | ||||
model_objs.append(converter_fn(obj)) | model_objs.append(converter_fn(obj)) | ||||
storage.origin_add(origins) | storage.origin_add(origins) | ||||
method = getattr(storage, f"{object_type}_add") | method = getattr(storage, f"{object_type}_add") | ||||
method(model_objs) | method(model_objs) | ||||
elif object_type in ("directory", "revision", "release", "snapshot", "origin",): | elif object_type in ("directory", "revision", "release", "snapshot", "origin",): | ||||
method = getattr(storage, object_type + "_add") | method = getattr(storage, object_type + "_add") | ||||
method(object_converter_fn[object_type](o) for o in objects) | method([object_converter_fn[object_type](o) for o in objects]) | ||||
else: | else: | ||||
logger.warning("Received a series of %s, this should not happen", object_type) | logger.warning("Received a series of %s, this should not happen", object_type) |