Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/storage.py
Show First 20 Lines • Show All 1,021 Lines • ▼ Show 20 Lines | class Storage(): | ||||
def origin_add_one(self, origin: Origin, db=None, cur=None) -> str: | def origin_add_one(self, origin: Origin, db=None, cur=None) -> str: | ||||
origin_row = list(db.origin_get_by_url([origin.url], cur))[0] | origin_row = list(db.origin_get_by_url([origin.url], cur))[0] | ||||
origin_url = dict(zip(db.origin_cols, origin_row))['url'] | origin_url = dict(zip(db.origin_cols, origin_row))['url'] | ||||
if origin_url: | if origin_url: | ||||
return origin_url | return origin_url | ||||
self.journal_writer.origin_add_one(origin) | self.journal_writer.origin_add_one(origin) | ||||
origins = db.origin_add(origin.url, cur) | url = db.origin_add(origin.url, cur) | ||||
send_metric('origin:add', count=len(origins), method_name='origin_add') | send_metric('origin:add', count=1, method_name='origin_add_one') | ||||
return origins | return url | ||||
@db_transaction(statement_timeout=500) | @db_transaction(statement_timeout=500) | ||||
def stat_counters(self, db=None, cur=None): | def stat_counters(self, db=None, cur=None): | ||||
return {k: v for (k, v) in db.stat_counters()} | return {k: v for (k, v) in db.stat_counters()} | ||||
@db_transaction() | @db_transaction() | ||||
def refresh_stat_counters(self, db=None, cur=None): | def refresh_stat_counters(self, db=None, cur=None): | ||||
keys = [ | keys = [ | ||||
▲ Show 20 Lines • Show All 102 Lines • Show Last 20 Lines |