Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 674 Lines • ▼ Show 20 Lines | def release_add(self, releases: List[Release], db=None, cur=None) -> Dict: | ||||
db.copy_to(releases_filtered, "tmp_release", db.release_add_cols, cur) | db.copy_to(releases_filtered, "tmp_release", db.release_add_cols, cur) | ||||
db.release_add_from_temp(cur) | db.release_add_from_temp(cur) | ||||
return {"release:add": len(releases_missing)} | return {"release:add": len(releases_missing)} | ||||
@timed | @timed | ||||
@db_transaction_generator() | @db_transaction_generator() | ||||
def release_missing(self, releases, db=None, cur=None): | def release_missing( | ||||
self, releases: List[Sha1Git], db=None, cur=None | |||||
) -> Iterable[Sha1Git]: | |||||
if not releases: | if not releases: | ||||
return | return | ||||
for obj in db.release_missing_from_list(releases, cur): | for obj in db.release_missing_from_list(releases, cur): | ||||
yield obj[0] | yield obj[0] | ||||
@timed | @timed | ||||
@db_transaction_generator(statement_timeout=500) | @db_transaction_generator(statement_timeout=500) | ||||
▲ Show 20 Lines • Show All 743 Lines • Show Last 20 Lines |