Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/retry.py
Show First 20 Lines • Show All 93 Lines • ▼ Show 20 Lines | class RetryingProxyStorage: | ||||
@swh_retry | @swh_retry | ||||
def origin_visit_add(self, origin: Origin, | def origin_visit_add(self, origin: Origin, | ||||
date: Union[datetime, str], type: str) -> OriginVisit: | date: Union[datetime, str], type: str) -> OriginVisit: | ||||
return self.storage.origin_visit_add(origin, date, type) | return self.storage.origin_visit_add(origin, date, type) | ||||
@swh_retry | @swh_retry | ||||
def origin_visit_update( | def origin_visit_update( | ||||
self, origin: str, visit_id: int, status: Optional[str] = None, | self, visit: OriginVisit, status: Optional[str] = None, | ||||
metadata: Optional[Dict] = None, | metadata: Optional[Dict] = None, | ||||
snapshot: Optional[Dict] = None) -> Dict: | snapshot: Optional[Dict] = None) -> None: | ||||
return self.storage.origin_visit_update( | return self.storage.origin_visit_update( | ||||
origin, visit_id, status=status, | visit, status=status, | ||||
metadata=metadata, snapshot=snapshot) | metadata=metadata, snapshot=snapshot) | ||||
@swh_retry | @swh_retry | ||||
def tool_add(self, tools: Iterable[Dict]) -> List[Dict]: | def tool_add(self, tools: Iterable[Dict]) -> List[Dict]: | ||||
tools = list(tools) | tools = list(tools) | ||||
return self.storage.tool_add(tools) | return self.storage.tool_add(tools) | ||||
@swh_retry | @swh_retry | ||||
Show All 37 Lines |