Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 816 Lines • ▼ Show 20 Lines | ) -> Iterable[OriginVisit]: | ||||
nb_visits += 1 | nb_visits += 1 | ||||
if not visit.visit: | if not visit.visit: | ||||
with convert_validation_exceptions(): | with convert_validation_exceptions(): | ||||
visit_id = db.origin_visit_add( | visit_id = db.origin_visit_add( | ||||
visit.origin, visit.date, visit.type, cur=cur | visit.origin, visit.date, visit.type, cur=cur | ||||
) | ) | ||||
visit = attr.evolve(visit, visit=visit_id) | visit = attr.evolve(visit, visit=visit_id) | ||||
else: | else: | ||||
db.origin_visit_upsert(visit) | db.origin_visit_add_with_id(visit) | ||||
olasd: Missing cursor argument | |||||
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 = OriginVisitStatus( | visit_status = OriginVisitStatus( | ||||
origin=visit.origin, | origin=visit.origin, | ||||
visit=visit.visit, | visit=visit.visit, | ||||
date=visit.date, | date=visit.date, | ||||
▲ Show 20 Lines • Show All 586 Lines • Show Last 20 Lines |
Missing cursor argument