Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 978 Lines • ▼ Show 20 Lines | ) -> Optional[Dict[str, Any]]: | ||||
return self._origin_visit_apply_update(visit_dict, db) | return self._origin_visit_apply_update(visit_dict, db) | ||||
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, | |||||
allowed_statuses: Optional[List[str]] = None, | allowed_statuses: Optional[List[str]] = None, | ||||
require_snapshot: bool = False, | require_snapshot: bool = False, | ||||
db=None, | db=None, | ||||
cur=None, | cur=None, | ||||
) -> Optional[Dict[str, Any]]: | ) -> Optional[Dict[str, Any]]: | ||||
row = db.origin_visit_get_latest( | row = db.origin_visit_get_latest( | ||||
origin, | origin, | ||||
type=type, | |||||
allowed_statuses=allowed_statuses, | allowed_statuses=allowed_statuses, | ||||
require_snapshot=require_snapshot, | require_snapshot=require_snapshot, | ||||
cur=cur, | cur=cur, | ||||
) | ) | ||||
if row: | if row: | ||||
visit = dict(zip(db.origin_visit_get_cols, row)) | visit = dict(zip(db.origin_visit_get_cols, row)) | ||||
return self._origin_visit_apply_update(visit, db) | return self._origin_visit_apply_update(visit, db) | ||||
return None | return None | ||||
▲ Show 20 Lines • Show All 327 Lines • Show Last 20 Lines |