Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 923 Lines • ▼ Show 20 Lines | class Storage: | ||||
@timed | @timed | ||||
@db_transaction_generator(statement_timeout=500) | @db_transaction_generator(statement_timeout=500) | ||||
def origin_visit_get( | def origin_visit_get( | ||||
self, | self, | ||||
origin: str, | origin: str, | ||||
last_visit: Optional[int] = None, | last_visit: Optional[int] = None, | ||||
limit: Optional[int] = None, | limit: Optional[int] = None, | ||||
order: str = "asc", | |||||
db=None, | db=None, | ||||
cur=None, | cur=None, | ||||
) -> Iterable[Dict[str, Any]]: | ) -> Iterable[Dict[str, Any]]: | ||||
assert order in ["asc", "desc"] | |||||
lines = db.origin_visit_get_all( | lines = db.origin_visit_get_all( | ||||
origin, last_visit=last_visit, limit=limit, cur=cur | origin, last_visit=last_visit, limit=limit, order=order, cur=cur | ||||
) | ) | ||||
for line in lines: | for line in lines: | ||||
visit = dict(zip(db.origin_visit_get_cols, line)) | visit = dict(zip(db.origin_visit_get_cols, line)) | ||||
yield self._origin_visit_apply_update(visit, db) | yield self._origin_visit_apply_update(visit, db) | ||||
@timed | @timed | ||||
@db_transaction(statement_timeout=500) | @db_transaction(statement_timeout=500) | ||||
def origin_visit_find_by_date( | def origin_visit_find_by_date( | ||||
▲ Show 20 Lines • Show All 370 Lines • Show Last 20 Lines |