Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/cassandra/cql.py
| Show First 20 Lines • Show All 831 Lines • ▼ Show 20 Lines | ) -> Optional[OriginVisitStatusRow]: | ||||
| """ | """ | ||||
| return next(self.origin_visit_status_get(origin, visit), None) | return next(self.origin_visit_status_get(origin, visit), None) | ||||
| @_prepared_select_statement( | @_prepared_select_statement( | ||||
| OriginVisitStatusRow, "WHERE origin = ? AND visit = ? ORDER BY date DESC" | OriginVisitStatusRow, "WHERE origin = ? AND visit = ? ORDER BY date DESC" | ||||
| ) | ) | ||||
| def origin_visit_status_get( | def origin_visit_status_get( | ||||
| self, | self, origin: str, visit: int, *, statement, | ||||
| origin: str, | |||||
| visit: int, | |||||
| allowed_statuses: Optional[List[str]] = None, | |||||
| require_snapshot: bool = False, | |||||
| *, | |||||
| statement, | |||||
| ) -> Iterator[OriginVisitStatusRow]: | ) -> Iterator[OriginVisitStatusRow]: | ||||
| """Return all origin visit statuses for a given visit | """Return all origin visit statuses for a given visit | ||||
| """ | """ | ||||
| return map( | return map( | ||||
| OriginVisitStatusRow.from_dict, | OriginVisitStatusRow.from_dict, | ||||
| self._execute_with_retries(statement, [origin, visit]), | self._execute_with_retries(statement, [origin, visit]), | ||||
| ) | ) | ||||
| ▲ Show 20 Lines • Show All 160 Lines • Show Last 20 Lines | |||||