Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/cassandra/cql.py
Show First 20 Lines • Show All 649 Lines • ▼ Show 20 Lines | class CqlRunner: | ||||
# 'origin_visit' table | # 'origin_visit' table | ||||
########################## | ########################## | ||||
_origin_visit_keys = [ | _origin_visit_keys = [ | ||||
"origin", | "origin", | ||||
"visit", | "visit", | ||||
"type", | "type", | ||||
"date", | "date", | ||||
"status", | |||||
"metadata", | |||||
"snapshot", | |||||
] | ] | ||||
@_prepared_statement("SELECT * FROM origin_visit WHERE origin = ? AND visit > ?") | @_prepared_statement("SELECT * FROM origin_visit WHERE origin = ? AND visit > ?") | ||||
def _origin_visit_get_no_limit( | def _origin_visit_get_no_limit( | ||||
self, origin_url: str, last_visit: int, *, statement | self, origin_url: str, last_visit: int, *, statement | ||||
) -> ResultSet: | ) -> ResultSet: | ||||
return self._execute_with_retries(statement, [origin_url, last_visit]) | return self._execute_with_retries(statement, [origin_url, last_visit]) | ||||
▲ Show 20 Lines • Show All 236 Lines • Show Last 20 Lines |