Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 817 Lines • ▼ Show 20 Lines | ) -> Iterable[OriginVisit]: | ||||
) | ) | ||||
visit = attr.evolve(visit, visit=visit_id) | visit = attr.evolve(visit, visit=visit_id) | ||||
else: | else: | ||||
db.origin_visit_upsert(visit) | db.origin_visit_upsert(visit) | ||||
assert visit.visit is not None | assert visit.visit is not None | ||||
all_visits.append(visit) | all_visits.append(visit) | ||||
# Forced to write after for the case when the visit has no id | # Forced to write after for the case when the visit has no id | ||||
self.journal_writer.origin_visit_add([visit]) | self.journal_writer.origin_visit_add([visit]) | ||||
visit_status_dict = visit.to_dict() | visit_status = OriginVisitStatus( | ||||
visit_status_dict.pop("type") | origin=visit.origin, | ||||
visit_status = OriginVisitStatus.from_dict(visit_status_dict) | visit=visit.visit, | ||||
date=visit.date, | |||||
status="created", | |||||
snapshot=None, | |||||
) | |||||
self._origin_visit_status_add(visit_status, db=db, cur=cur) | self._origin_visit_status_add(visit_status, db=db, cur=cur) | ||||
send_metric("origin_visit:add", count=nb_visits, method_name="origin_visit") | send_metric("origin_visit:add", count=nb_visits, method_name="origin_visit") | ||||
return all_visits | return all_visits | ||||
def _origin_visit_status_add( | def _origin_visit_status_add( | ||||
self, visit_status: OriginVisitStatus, db, cur | self, visit_status: OriginVisitStatus, db, cur | ||||
) -> None: | ) -> None: | ||||
▲ Show 20 Lines • Show All 474 Lines • Show Last 20 Lines |