Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/db.py
Show First 20 Lines • Show All 441 Lines • ▼ Show 20 Lines | def origin_visit_add(self, origin, ts, type, cur=None): | ||||
"SELECT swh_origin_visit_add(%s, %s, %s)", (origin, ts, type) | "SELECT swh_origin_visit_add(%s, %s, %s)", (origin, ts, type) | ||||
) | ) | ||||
return cur.fetchone()[0] | return cur.fetchone()[0] | ||||
origin_visit_status_cols = [ | origin_visit_status_cols = [ | ||||
"origin", | "origin", | ||||
"visit", | "visit", | ||||
"date", | "date", | ||||
"type", | |||||
"status", | "status", | ||||
"snapshot", | "snapshot", | ||||
"metadata", | "metadata", | ||||
] | ] | ||||
def origin_visit_status_add( | def origin_visit_status_add( | ||||
self, visit_status: OriginVisitStatus, cur=None | self, visit_status: OriginVisitStatus, cur=None | ||||
) -> None: | ) -> None: | ||||
▲ Show 20 Lines • Show All 51 Lines • ▼ Show 20 Lines | origin_visit_select_cols = [ | ||||
"ovs.metadata", | "ovs.metadata", | ||||
"ovs.snapshot", | "ovs.snapshot", | ||||
] | ] | ||||
origin_visit_status_select_cols = [ | origin_visit_status_select_cols = [ | ||||
"o.url AS origin", | "o.url AS origin", | ||||
"ovs.visit", | "ovs.visit", | ||||
"ovs.date", | "ovs.date", | ||||
"ovs.type", | |||||
"ovs.status", | "ovs.status", | ||||
"ovs.snapshot", | "ovs.snapshot", | ||||
"ovs.metadata", | "ovs.metadata", | ||||
] | ] | ||||
def _make_origin_visit_status( | def _make_origin_visit_status( | ||||
self, row: Optional[Tuple[Any]] | self, row: Optional[Tuple[Any]] | ||||
) -> Optional[Dict[str, Any]]: | ) -> Optional[Dict[str, Any]]: | ||||
▲ Show 20 Lines • Show All 830 Lines • Show Last 20 Lines |