Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 907 Lines • ▼ Show 20 Lines | ) -> Optional[OriginVisit]: | ||||
date=row_d["date"], | date=row_d["date"], | ||||
type=row_d["type"], | type=row_d["type"], | ||||
) | ) | ||||
@timed | @timed | ||||
@db_transaction(statement_timeout=500) | @db_transaction(statement_timeout=500) | ||||
def origin_visit_get_by( | def origin_visit_get_by( | ||||
self, origin: str, visit: int, db=None, cur=None | self, origin: str, visit: int, db=None, cur=None | ||||
) -> Optional[Dict[str, Any]]: | ) -> Optional[OriginVisit]: | ||||
row = db.origin_visit_get(origin, visit, cur) | row = db.origin_visit_get(origin, visit, cur) | ||||
if row: | if row: | ||||
return dict(zip(db.origin_visit_get_cols, row)) | row_d = dict(zip(db.origin_visit_get_cols, row)) | ||||
return OriginVisit( | |||||
origin=row_d["origin"], | |||||
visit=row_d["visit"], | |||||
date=row_d["date"], | |||||
type=row_d["type"], | |||||
) | |||||
return None | return None | ||||
@timed | @timed | ||||
@db_transaction(statement_timeout=4000) | @db_transaction(statement_timeout=4000) | ||||
def origin_visit_get_latest( | def origin_visit_get_latest( | ||||
self, | self, | ||||
origin: str, | origin: str, | ||||
type: Optional[str] = None, | type: Optional[str] = None, | ||||
▲ Show 20 Lines • Show All 410 Lines • Show Last 20 Lines |