Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/retry.py
Show First 20 Lines • Show All 162 Lines • ▼ Show 20 Lines | class RetryingProxyStorage: | ||||
@swh_retry | @swh_retry | ||||
def release_add(self, releases: Iterable[Release]) -> Dict: | def release_add(self, releases: Iterable[Release]) -> Dict: | ||||
return self.storage.release_add(releases) | return self.storage.release_add(releases) | ||||
@swh_retry | @swh_retry | ||||
def snapshot_add(self, snapshots: Iterable[Snapshot]) -> Dict: | def snapshot_add(self, snapshots: Iterable[Snapshot]) -> Dict: | ||||
return self.storage.snapshot_add(snapshots) | return self.storage.snapshot_add(snapshots) | ||||
@swh_retry | def clear_buffers(self, object_types: Optional[Iterable[str]] = None) -> None: | ||||
return self.storage.clear_buffers(object_types) | |||||
def flush(self, object_types: Optional[Iterable[str]] = None) -> Dict: | def flush(self, object_types: Optional[Iterable[str]] = None) -> Dict: | ||||
"""Specific case for buffer proxy storage failing to flush data | """Specific case for buffer proxy storage failing to flush data | ||||
""" | """ | ||||
if hasattr(self.storage, "flush"): | |||||
return self.storage.flush(object_types) | return self.storage.flush(object_types) | ||||
return {} | |||||
def clear_buffers(self, object_types: Optional[Iterable[str]] = None) -> None: | |||||
return self.storage.clear_buffers(object_types) |