Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 1,087 Lines • ▼ Show 20 Lines | ) -> Optional[Tuple[OriginVisit, OriginVisitStatus]]: | ||||
metadata=row_d["metadata"], | metadata=row_d["metadata"], | ||||
snapshot=row_d["snapshot"], | snapshot=row_d["snapshot"], | ||||
) | ) | ||||
return visit, visit_status | return visit, visit_status | ||||
return None | return None | ||||
@timed | @timed | ||||
@db_transaction(statement_timeout=2000) | @db_transaction(statement_timeout=2000) | ||||
def object_find_by_sha1_git(self, ids, db=None, cur=None): | def object_find_by_sha1_git( | ||||
ret = {id: [] for id in ids} | self, ids: List[Sha1Git], db=None, cur=None | ||||
) -> Dict[Sha1Git, List[Dict]]: | |||||
ret: Dict[Sha1Git, List[Dict]] = {id: [] for id in ids} | |||||
for retval in db.object_find_by_sha1_git(ids, cur=cur): | for retval in db.object_find_by_sha1_git(ids, cur=cur): | ||||
if retval[1]: | if retval[1]: | ||||
ret[retval[0]].append( | ret[retval[0]].append( | ||||
dict(zip(db.object_find_by_sha1_git_cols, retval)) | dict(zip(db.object_find_by_sha1_git_cols, retval)) | ||||
) | ) | ||||
return ret | return ret | ||||
▲ Show 20 Lines • Show All 340 Lines • Show Last 20 Lines |