Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/cassandra/model.py
Show First 20 Lines • Show All 185 Lines • ▼ Show 20 Lines | class OriginVisitRow(BaseRow): | |||||||||
date: datetime.datetime | date: datetime.datetime | |||||||||
type: str | type: str | |||||||||
@dataclasses.dataclass | @dataclasses.dataclass | |||||||||
class OriginVisitStatusRow(BaseRow): | class OriginVisitStatusRow(BaseRow): | |||||||||
TABLE = "origin_visit_status" | TABLE = "origin_visit_status" | |||||||||
PARTITION_KEY = ("origin",) | PARTITION_KEY = ("origin",) | |||||||||
CLUSTERING_KEY = ("visit", "date") | CLUSTERING_KEY = ("visit", "date") | |||||||||
vlorentzUnsubmitted Not Done Inline Actions
vlorentz: | ||||||||||
origin: str | origin: str | |||||||||
visit: int | visit: int | |||||||||
date: datetime.datetime | date: datetime.datetime | |||||||||
type: str | ||||||||||
status: str | status: str | |||||||||
metadata: str | metadata: str | |||||||||
snapshot: bytes | snapshot: bytes | |||||||||
@classmethod | @classmethod | |||||||||
def from_dict(cls: Type[T], d: Dict[str, Any]) -> T: | def from_dict(cls: Type[T], d: Dict[str, Any]) -> T: | |||||||||
d = d.copy() | ||||||||||
d.pop("type", None) | ||||||||||
return cls(**d) # type: ignore | return cls(**d) # type: ignore | |||||||||
@dataclasses.dataclass | @dataclasses.dataclass | |||||||||
class OriginRow(BaseRow): | class OriginRow(BaseRow): | |||||||||
TABLE = "origin" | TABLE = "origin" | |||||||||
PARTITION_KEY = ("sha1",) | PARTITION_KEY = ("sha1",) | |||||||||
▲ Show 20 Lines • Show All 69 Lines • Show Last 20 Lines |